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…
Futex 在进入到brpc之前，先看看linux的futex是怎么用的。 man page中有比较详细的描述 可以把futex看作是一个原子的compare-and-block，他会原子的比较目标地址上的值，并进入睡眠。 通常的用法就是我们先通过一个用户空间的原子量来表示锁。当一个线程发现锁已经被获得了以后，他就会通过futex来睡眠，直到锁不再被其他人占有。 （感觉实现起来需要特殊处理signal，我们只要保证signal不出现在compare和block之间，就不会出现lost wakeup的问题） fute…
bthread 线程知识 bthread文档 bthread很关键的一点和协程的不同就是当bthread被阻塞的时候，同一个pthread下的其他bthread不会被阻塞，而是会被其他的pthread偷走运行。 bthread的启动函数 bthread中的一个task group对应了一个worker，可以看到他是从tls中取task group的，所以可以想到是一个pthread对应一个task group 如果没有task group的话，说明当前的pthread不是bthread worker。所以我们就调用…
IO(2) 我之前画的一个图，表示RPC的通信过程。 上一次说了server端是怎么接受请求并处理的，这一次看看客户端这边的处理。 我们在通过Stub调用RPC的时候，会调用到channel.CallMethod中 void EchoService_Stub::Echo(::google::protobuf::RpcController* controller, const ::EchoRequest* request, ::EchoResponse* response, ::google::protobuf::C…
记录一下在读brpc的时候学习到的点 ResourcePool ResourceID来标识资源。虽然不同的类型有不同类型的ResourcID，但是内部都是一个uint64 存储数据的是Block。当线程需要内存的时候，他就会分配一个block。每个block内部的数据只会被一个线程使用 一个block就相当于是一个小的DataPool 若干个block组成一个block group。BlockGroup通过指针数组索引block LocalPool是thread local的data pool 一个比较有意思的点就…
Raft-KV 这里写一下lab4 shardkv的思路吧，感觉如果不好好想一下设计细节的话写代码的时候就很容易乱套 目标就是完成所有的part，所以后面的选做部分也要实现（其实感觉不实现那我们的代码就太玩具了） 每个shard不能干扰其他的shard，比如一个shard正在等待数据，他是不能干扰其他shard完成正常操作的。所以我们分别维护每个shard的状态。每个shard有自己的map 去重表，可以放在shard外面也可以放在shard里面，我这里就选择放在shard里面 有一个定时向shardctrler去…
Daily C/C++ 新版本C++中的易用性改进 参考文章 首先就是auto，自动类型推导 auto可以帮助我们推导表达式的类型，同时这是编译期发生的事，所以和我们自己写类型是一样的，不过可以帮助我们写出更加通用简洁的代码 比如这段代码 template <typename T> void foo(const T& c) { using std::begin; using std::end; for (auto it = begin(c), ite = end(c); it != ite; +…