letsfire

Results 17 comments of letsfire

感谢,这段工作较忙,问题已经修复,使用了sync.Map,您的测试用例已通过。再次感谢

还请指点,resetGuard里面是多,但是这段代码执行少,复杂度可以忽略吧

确保只有一个协程能重置m.cursor

`m.workers.Load(idx)` 同一时间会有多个协程拿不到worker进而去下面重置cursor,这时候下面的guard就是仅让其中一个协程进行重置,其他等待重置完毕继续获取从头获取

第一个问题,我已经先把work标记成busy了,不会再有新写入进入了吧 第二个问题周末修复一下,感谢您的反馈

我加了一个定时器解决您提的这个问题,至于action出错,我的设想是action自行处理的,line.go里面也有SetPanicHandler,worker.go里的process也只是防止worker死掉,出错了组件这里也是不知道怎么回补的,这些应该action自己处理吧

Thank you. With your reminder, I have resolved my issue.