这不是典型的 hbase 场景吗？又便宜又好用写入性能好

node 已经不太行了。。

Folly：facebook c++ 开源工具库

先说结论：要在 main 中感知任务的完成状态可以通过 chan，控制数据流转也是用 chan，如果有超时机制或者每个任务属性之类数据需要用到 context 。

1 ）步骤大约是
main 函数中创建三个用于接受结果的 A B C chan，大小为 A 任务个数，和一个 notify chan 用于完成通知，再来一个通知主程序关闭的 doneChan

起一个 goruntine 去 for notify chan
go func() {
for a := range nChan {
if (ACount == BCount == CCount == 100) {
doneChan <- struct{}
}

}
}


起三个 goruntine 去 for 分别处理 A B C chan，里面写处理逻辑，大约是这样子
go func(nChan chan Notify) {
for a := range AChan {
// dosomething

if ok {
bChan <- weiboEntryID
} else {
nChan <- weiboEntryID
}
}
close(bChan)
}(nChan)

go func(chan Notify) {
for b := range BChan {
// dosomething

if ok {
cChan <- commentID
} else {
nChan <- commentID
}
}
close(cChan)
}(nChan)

go func(chan Notify) {
for c := range CChan {
// dosomething

if ok {
cChan <- commentUserID
} else {
nChan <- commentUserID
}
}
}(nChan)

这时候就 main 中可以往 AChan 里写数据了，写完直接 close AChan，然后直接用 doneChan 阻塞

for userID := range userIDs {
AChan <- userID
}
close(aChan)
<-doneChan


大致流程就是这样，需要注意的是需要正确关闭 ABC chan，就是在发送完成后关闭，nChan 用于任务信息回收还可以用于任务回放，另外为了保证每个任务都会返回，需要弄一个 timeout context 超时当作失败处理

2 ）第二种情况，由于任务个数是未知的，上面的 100 就不能用了，有两种方式可以解决，一是可以预先知道每次数量，用另外的一个 chan 再任务开始时候传给发送 doneChan 那个 goruntine，把 100 改成最后总数即可。二是未知任务数量，这时候只能再来一个 chan，在做完 ABC 后发送一个 aDone 、bDone 、cDone，给发送 doneChan 那个 goruntine，当确认三个都完成后，就可以发送 done 了。

------

code 硬敲的可能很多不对，变量和具体结构可酌情改变 :-)

钱多事少离家近

泉州有啥公司？？

只会命令行。。。

不太同意楼上大大们的观点，作为计算机三大基础，我认为还是有必要花时间好好看看的，但是队伍吾等 curd boy + game boy 时间有限，感觉看的顺序应该是《操作系统》> 《编译原理》> 《计算机网络》

ps：《 tcp/ip 详解》确实过于专业枯燥了，可以先从简单的入手，比如《图解 tcp/ip 》

基本上就钉钉和飞书找一个把？如果比较依赖外部的会用企业微信把。。。

https://docs.python.org/zh-cn/3/library/multiprocessing.html#using-a-pool-of-workers

有 timeout 参数，会抛出异常，另外 "最后让所有的进程都在 10s 内成功运行完成" 你得有足够的进程数量

大佬收下我的膝盖

@wanacry ？？？？？？？？？？？？？？？？？？？？？？？？？？？？？？？？？？？？？？

这么快就忘记 gitlab 黑历史吗？
https://news.ycombinator.com/item?id=21437334

再说了 github 足够好用

编制只的是通过正规公务员或者事业单位同时考试面试之后才会有的，给发钱是国家或者国家发一部分单位发一部分

看楼主 应该不是通过考试进去的，就是普通的合同工，从工作性质上来说等同私企。

另外国企单位也是有好处的，就是真的安逸。。。