letsfire
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.