- 博客(59)
- 资源 (1)
- 收藏
- 关注
RSS订阅
原创 [rUDP] KCP梳理
背景先介绍下写这篇博客时的背景。无意间就看到了某视频网站需要懂KCP、UDT这类RUDP协议的开发人员，随即投了份简历。因此，这篇博客算是一份对过往知识的梳理，同时也算是一次面试的准备过程。讲真，在当前这个Java横行的年代，坚守C/C++真的不容易；而去搞KCP、UDT等这类RUDP如此底层的玩意，就更少之又少了。至于我为什么会接触RUDP这块，应该也算是研究生阶段的研究方向。当时刚上研究生...
2018-09-11 00:23:04
3722
2
原创 [evpp/muduo/reactor] evpp事件驱动网络库 整体架构梳理 2
序上一篇博文中，我们从用户使用的角度入手，对evpp中TCPServer、TCPClient两大类进行了梳理。接下来，我们再来分析梳理下Listener、Connector两个类的细节。当然，这让我联想起了杨宗纬的那首歌“如果你愿意一层一层一层地剥开我的心，你会发现 你会讶异…”。扯得有点远，让我们进入正题。ListenerListener正如其名，主要是封装和TCPServer ...
2018-09-06 17:15:19
1275
原创 [evpp/muduo/reactor] evpp事件驱动网络库 整体架构梳理
介绍muduo很多人都听说过，那evpp可以理解成是muduo用C++11改写后的升级版。 相比muduo的代码风格，evpp会显得更加现代一点，更讨我们年轻人的喜欢。 作为例子，这里是一段TCP Echo Server的示例代码： std::string addr = "0.0.0.0:9099&
2018-09-03 01:06:16
2836
2
原创 [C++11] 线程安全的BoundedBlockingQueue
template <typename T>class BoundedBlockingQueue {public: explicit BoundedBlockingQueue(int maxSize) : ringbuffer(maxSize) { } void put(const T& x) { std::unique_lock&...
2020-10-05 02:14:09
913
原创 bprc-bthread梳理
BRPC是baidu内部自研的一套RPC框架，除了易用性、高性能之外，核心的一个亮点就是当中完整实现了一套M->N的Green Threading（类似Golang的Goroutine）。1）BRPC在公司内部大量使用，每天的工作基本上都绕着brpc转也不为过；2）因为自己最早是写C出身的，自然对Golang喜欢的不行，Goroutine也用得不要太开心，但是一直没有对Goroutine的原理进行学习。借此机会，希望通过对bthread的梳理，能管中窥豹M->N Green Threadi
2020-10-01 13:09:14
508
原创 [Kafka权威指南] Chapter 4. Kafka消费者：消费数据
Consumer GroupWhat is Consumer Group ?Case：前端采集的数据通过Kafka Topic回传至后端分析程序，但是单个分析线程（Consumer）很有可能忙不过来。既然单个消费者忙不过来，那就多来几个消费者。此时，这些消费者就构成了一个小团队。Topic中的消息在被分割、摊派后，每个成员（消费者）就自顾自地忙自己那部分。在Kafka中，这个团...
2019-04-29 19:55:50
393
原创 [Kafka权威指南] Chapter 1. 初识Kafka
What is Kafka?基于“发布/订阅”模型的消息队列Why Kafka?多生产者 方便数据聚合 多消费者 多个消费者同时消费同一个消息流，消息可以被多次重复消费。 多个消费者可以组成一个Group，保证特定消息只消费一次。 消息持久化 消费者不需要战战兢兢地消费消息，就算忙不过来，Kafka也能缓一下 可扩展 高性能Basic ...
2019-04-28 18:42:55
206
原创 [LevelDB] 一步步剖析AtomicPointer
AtomicPointer是LevelDB中的一个基础数据结构，其核心代码只有寥寥10来行。但是，为了理解这10来行代码，却需要十分扎实的CPU架构、操作系统、编译器、C++11知识。为了搞明白其背后的原理，同时加深理解，我准备从以下几点着手，一步步抽丝剥茧：什么是乱序执行？ 什么是Memory Barrier ？ Platform-Specific的AtomicPointer实...
2019-03-04 00:32:10
301
原创 [C++11] 万能引用总结
针对左值，万能引用等效左值引用；针对右值，万能引用等效右值引用； 针对左/右值，万能引用都正确进行了推导，那为啥还要有std::forward? 因为右值引用是左值！！万恶之源 有点绕，为啥右值引用是左值？ 右值，就是“无名”的value，只有值，没有变量名； 右值引用，本身就是一个变量，当然是左值； 右值引用在绑定了右值后，为右值增加了一个“句柄”，这样看也当然是左值...
2019-01-14 21:15:50
2151
原创 [C++11] ThreadPool
背景近期，在造一个异步HTTP调用的轮子；https://github.com/Sai-Jiang简单来说，通过一个Restful接口，代理会接收异步HTTP调用的请求；这些接收到的异步HTTP调用请求，将会由代理代为去执行；适用的场景，主要是低时延接口调用高时延接口；HTTP的调用，目前准备用线程池来做；线程池实现中的任务队列，我就直接复用了之前博客中的BoundedBl...
2018-10-16 23:51:23
545
原创 [C++] 适用程序退出的Signal Handler
To the point#include <csignal>#include <glog/logging.h>#include <mutex>#include <condition_variable>class SignalHandler {public: SignalHandler() = delete; st...
2018-10-16 16:17:58
2210
原创 [C++采坑实录] Lambda按值捕获 和 array
背景 一个学环境的朋友，正准备转码农，今天碰巧遇到一个Bug。这里，我把代码简化之后，来看看到底哪里出现了问题？ 代码int main() { int collection[5] = {}; auto process = [=]() { // 按值捕获 for(int i : collection) std:...
2018-10-12 23:44:59
2003
7
原创 [N周N语言] C++实现Golang中的WaitGroup
class WaitGroup {public: void Add(int incr = 1) { counter += incr; } void Done() { counter--; if (counter <= 0) cond.notify_all(); } void ...
2018-10-10 22:15:05
589
原创 [C++11] 线程安全的BlockingQueue
参照muduo中的源码，使用C++11语法进行改写#include <mutex>#include <condition_variable>#include <deque>template <typename T>class BlockingQueue {public: BlockingQueue() : mutex_(), c...
2018-10-10 21:07:43
983
原创 [kafka] Kafka Docker单机环境搭建
Kafka搭建docker pull wurstmeister/zookeeperdocker pull wurstmeister/kafkadocker run -d --name zookeeper -p 2181:2181 -t wurstmeister/zookeeper docker run -d --name kafka --publish 9092:9092 \--l...
2018-10-09 12:07:22
3128
1
原创 [N周N语言] Golang for range，C++ auto for 遍历时是否可以删除元素？
先说下结论Golang中的map，是可以在for range时删除元素的；但是，不能取元素的地址；C++中的auto for，则是不支持删除元素的；
2018-10-06 20:48:10
1149
原创 [STL] lower_bound和upper_bound实现
int lower_bound(vector<int>& nums, int target) { int lo = 0, hi = nums.size() - 1; while (lo <= hi) { // equal int mid = lo + (hi - lo) / 2; ...
2018-10-05 15:45:22
1947
原创 [Leetcode] 124. Binary Tree Maximum Path Sum
Given a non-empty binary tree, find the maximum path sum.For this problem, a path is defined as any sequence of nodes from some starting node to any node in the tree along the parent-child connection...
2018-10-04 16:15:56
260
原创 [uService] Asynchronous Processing with Go using Kafka and MongoDB
参考文献：https://www.melvinvivas.com/developing-microservices-using-kafka-and-mongodb/
2018-10-03 00:30:49
146
原创 [C++] lock_guard vs unique_lock
Lock doesn’t have to taken right at the construction, you can pass the flag std::defer_lock during its construction to keep the mutex unlocked during construction.std::unique_lock<std::mutex>...
2018-10-01 02:27:37
304
原创 [C++11] 循环引用
前言虽然C++11中的智能指针，一定程度上简化了C++当中的内存管理；但是，shared_ptr<>的使用同时也引出了另一个问题：循环引用。例子让我们先来看一段示例代码。#include <iostream>#include <vector>#include <memory>using namespace std;class pa...
2018-09-30 13:01:52
6624
原创 [Socket] listen()之backlog参数
直奔主题The behavior of the backlog argument on TCP sockets changed with Linux 2.2.Now it specifies the queue length for completely established sockets waiting to beaccepted, instead of the number o...
2018-09-25 10:13:37
653
原创 [Linux] 内存映射IO
前言本科留给我最大的印象，就是大一愣头青死磕APUE。一眨眼，研究生阶段都快结束了。时间过的好快。上研究生之后，慢慢从C转到C++，Linux native API也用的越来越少。趁着最近面试这个机会，赶紧复习一下相关概念。内存映射IO 的优势使用内存映射IO来取代read()和write() 能简化代码逻辑，统一以内存的形式进行处理；特定场景下，能提供更好的性能；内存映射IO 为什...
2018-09-25 00:19:41
494
原创 [STL] vector会自动shrink嘛？
Q（头脑风暴）vector是最常用的STL容器；同时，vector的底层实现会自动处理underlying storage用完的情况，进行扩增。但是，当我们clear()或者erase()掉vector中的部分元素后，vector的underlying storage会自动shrink嘛？A答案是No，std::vector::shrink_to_fit()...
2018-09-24 11:20:42
336
原创 [Linux] 文件描述符和打开文件之间的关系
前言文件描述符、文件句柄和i-node之间的关系，应该是Linux Native Programming的基本功。Golang、C++11写久了之后，这些概念有些淡忘，今天顺便梳理下。铺垫为了搞清楚这当中的关系，我们首先要了解内核维护的3个数据结构：进程级的文件描述符表系统级的打开文件句柄文件系统级的i-node表进程级的文件描述符表单条表项，包括：文件描述符标志，如clo...
2018-09-23 22:36:13
301
原创 [C++] 如何声明一个同迭代器指向元素类型相同的变量？
Q假设算法中要声明一个变量，以"迭代器所指对象的类型”为类型，该怎么办？A1. C++11 auto在C++11当中，可以直接用auto关键词进行声明；auto var = *iter;2. function template的参数推导如果编译器不支持C++11，或者说我想知道auto背后的原理呢？这时候，就需要用上函数模板的参数推导了。template&lt;typename ...
2018-09-21 22:45:40
572
原创 [Golang] timer可能造成的内存泄漏
背景前两天，跟一位学长交流Golang；然后，他突然问我：你知道timer可能造成内存泄漏嘛？ 当时，甚是一脸懵逼，毕竟之前写的Agent测了好久，都没发现这个问题啊。今天，就索性了解了下。这里先说下结论，timer的误用可能造成某些等待timer的Goroutine无法正常退出，导致资源无法释放；（ps. 虽然的确算是内存泄漏，但是对于我这种写C出身的人来说，感觉还是怪怪的）接下来进入正题，...
2018-09-19 23:33:45
5053
原创 [Linux] Sleep睡眠线程还是进程？
sleep() causes the calling thread to sleep either until the number ofreal-time seconds specified in seconds have elapsed or until a signalarrives which is not ignored.参考文献：http://man7.org/linux/ma...
2018-09-19 20:36:59
1918
原创 [HTTP] 状态码301和302的区别
301 Permanently Moved 永久重定向被请求的资源永久移动到新位置；将来对此资源的任何引用都应该使用本响应返回的若干个URI之一；如果可能，客户端应当自动把请求地址修改为从服务器返回的地址。除非额外指定，否则这个响应也是可缓存的。301比较常用的场景是使用域名跳转。比如，我们访问 http://www.baidu.com 会跳转到 https://www.baidu.c...
2018-09-19 19:21:34
462
原创 [C++11] 线程安全的单例Singleton
饿汉模式class Singleton {public: static Singleton &amp;amp;amp;GetInstance() { static Singleton instance; return instance; }private: Singleton() = default; Singleton(const Singl...
2018-09-19 00:08:38
271
原创 [C/C++] volatile关键词
Volatile关键字Volatile关键词的第一个特性：易变性。所谓的易变性，在汇编层面反映出来，就是两条语句，下一条语句不会直接使用上一条语句中volatile变量的寄存器内容，而是重新从内存中读取。Volatile关键词的第二个特性：“不可优化”特性。volatile告诉编译器，不要对我这个变量进行各种激进的优化，甚至将变量直接消除，保证程序员写在代码中的指令，一定会被执行。...
2018-09-16 18:42:42
128
原创 [algs] TopK问题
int main() { int N, K; cin &gt;&gt; N &gt;&gt; K; // 请注意，针对TopK（最大的K个元素）问题，我们采用的是末位淘汰的思想； // 末位淘汰后，剩下来的自然而然就是最顶尖的选手； // 因此，这里用的是MinPQ，小根堆； priority_queue&lt;int, vector&lt;int...
2018-09-16 16:14:51
115
原创 [GeeksForGeeks] Bin Packing Problem (Minimize number of used Bins)
Given n items of different weights and bins each of capacity c, assign each item to a bin such that number of total used bins is minimized. It may be assumed that all items have weights smaller than b...
2018-09-16 16:02:15
240
原创 [TCP] TCP 40ms Magic Number
待梳理参考文献：http://www.cnblogs.com/wanpengcoder/p/5366156.html https://www.cnblogs.com/wajika/p/6573028.html
2018-09-12 22:52:22
481
原创 [C++] LRU实现
template &lt;typename Key, typename Val&gt;class LRUCache {public: LRUCache(int cache_size_) : cache_size(cache_size_) { }; void put(const int &amp;key, const int &amp;val) { auto i...
2018-09-05 11:12:57
498
原创 [STL] SGI STL红黑树实现的边界条件
背景SGI STL红黑树实现上的特殊点，在于红黑树有一个header辅助节点； - 该header的父节点为root节点； - 其左节点为当前二叉树中的最小值（最左）； - 其右节点为当前二叉树中的最大值（最右）； - 该节点本身就正好用来当做end迭代器；其初始化代码如下：void init() { header = new Node(); hea...
2018-09-02 14:52:59
222
原创 [Reactor] 如果不限制并发连接数可能会引发的问题?
对于reactor模式，listening socket是一种特殊的IO对象。当有新连接到来时，此socket变为可读，epoll_wait会返回这一事件，然后在事件处理器中调用accept获得新连接的socket，但是如果本机的file descriptor已经用尽，则accept会返回EMFILE，标志accept调用失败，新连接依旧在listen的连接池中没有取出来。既然没有socket文件...
2018-08-31 13:09:03
508
原创 [os] 优先级反转
优先级反转是指一个低优先级的任务持有一个被高优先级任务所需要的共享资源。高优先任务由于因资源缺乏而处于受阻状态，一直等到低优先级任务释放资源为止。而低优先级获得的CPU时间少，如果此时有优先级处于两者之间的任务，并且不需要那个共享资源，则该中优先级的任务反而超过这两个任务而获得CPU时间。如果高优先级等待资源时不是阻塞等待，而是忙循环，则可能永远无法获得资源，因为此时低优先级进程无法与高优先级进程...
2018-08-28 00:48:35
177
ECC(bell labs technical journal)
2014-09-19
空空如也
TA创建的收藏夹 TA关注的收藏夹
TA关注的人