Channel 这一次看看channel 之前我就画过这个图。channel的作用就是从client向server发送请求。核心方法就是CallMethod。 然后请求到server的时候会被event dispatcher拿出来，然后调用Process，即切割数据并处理。 因为brpc是基于protobuf这个框架的，所以他的channel base是继承自protobuf的RpcChannel Weight表示的是权重。不同类型的channel有不用的权重 而protobuf的RpcChannel的定义则更为简…

Socket bthread相关的基本上结束了。这次重新看一下socket 在官方文档中有说，Socket的作用是让我们可以在多线程环境下使用fd。我个人的理解就是要多线程使用需要两点，引用计数+锁。SocketID的作用类似弱引用指针，我们可以通过SocketID来获取对应socket的unique ptr。并且SocketID可以作为epoll的data，而weak ptr不可以。并且shared ptr和weak ptr不能阻止后续的引用。如果一个server要退出时，不断的有请求到来，那么引用计数可能迟迟不…

ExecutionQueue execution queue在brpc中已经有相关的文档。就在execution_queue.md中 可以看到这个execution queue最开始是实现多线程向同一个fd写数据。之前我们已经看到过他相关的机制了。就是通过原子交换来获得所有权。 execution queue的任务在另一个单独的线程中执行。并保证执行顺序和提交顺序一致。同时支持多线程并发提交任务。（这里的提交就是插入） 这个execution queue是泛型的，可以创建多个不同类型的execution queue…

Access Path Selection in Main-Memory Optimized Data Systems: Should I Scan or Should I Probe? Abstract 列式数据分析引擎的发展引起了一系列对scan operator的优化。比如column-group storage, vectorized execution, shared scans, working directly over compressed data, using SIMD and multi-co…

bthread remain 这一节把bthread相关的收收尾。把之前留下的坑填一下。 最主要的就是interrupt了 用来打断在butex上的睡眠 注释有说到如果当前bthread没有被阻塞的话，这次interrupt就会被记住，然后在下一次阻塞的时候进行检查。 这里先调用interrupt and consume waiters 通过原子操作把current waiter拿出来。这样我们就可以获得butex上对应的结点。 然后用erase from butex because of interruption…

TimerThread 这次我们看看timer thread 之前已经大概知道他是干什么的了。在注释中也比较清楚 即在指定时间运行指定任务。注意运行任务的是独立的一个线程，添加任务和删除任务还是由调用者进行，而不是通过一些事件去分发。 先看看成员变量 这个stop原子量很常见了，用来停掉无限循环的代码的 option指的是timer thread的一些配置 timer thread是通过哈希来定位具体的任务的。所以我们有若干个bucket mutex则用来保护nearest run time _thread则是用来…

butex Butex就是可以在pthread和bthread中通用的futex-link primitive 可以看到比较熟悉的API。创建，删除，wake，wait。 还有两个不是那么熟悉的，就是wake except，以及requeue 最开始的两个例子。对应了wait和wake的顺序。要么wait可以看到新的value，然后停止wait。要么wait被wake唤醒。 一个butex有一个原子量，也就是对应的futex-word。若干个等待者，还有一个lock 这里可以看出来和我们之前看的brpc内部的fut…

bthread API 这一次针对性的看看bthread.cpp这个文件的作用 主要是定义使用bthread的API的 这个之前提到过，是用来获取全局单例TaskControl的 用来设置最小的并发数量。可以看到当val大于当前的concurrency，也就是pthread worker数量的时候，我们就添加若干个worker来让他的并发数达到val 这个也提到过。start urgent会开始执行新的bthread，现有的bthread会被偷走 start background则是把bthread加入到任务队列中…

WorkStealingQueue 这次我们看看bthread比较关键的两个queue，work stealing queue，以及remote queue 先看work stealing queue 从这个成员变量就可以大概猜出来一些东西。这应该是一个循环队列类似的东西。最朴素的队列应该不太可能，因为性能太差。当然也有可能是一个batch一个batch的分配元素，如果是那样的话我们需要内部维护一个链表，但是这里看貌似什么都没有。 初始化部分可以看到我们是按照2的次幂的大小进行分配空间的 注释中可以看到，push可…

TaskGroup 这次针对性的看一看task group里面的内容 之前提到过，一个task group对应了一个pthread worker，里面包含了若干个待运行的bthread任务 cur meta就是当前执行的任务的信息 task control就是全局的控制点 pl之前我们也提过，是用来停闲置的worker的 steal seed和steal offset是用来计算我们要偷取哪个worker的任务的。因为我们要保证随机 rq是running queue，就是目前正在执行的bthread的queue re…