delay-queue icon indicating copy to clipboard operation
delay-queue copied to clipboard

pushToReadyQueue()与removeFromBucket()需要考虑事务

Open hb-chen opened this issue 6 years ago • 0 comments

在Push、Pop和tickHandler会使用<-bucketNameChan分配bucket 而在tickHandler中需要先pushToReadyQueue(),再removeFromBucket(),这个过程中如果Job被Pop(),并且pop后pushToBucket()取到的bucketName与原来相同,这时候时序会出问题,pop向bucket中写入新的timestamp,但随后被remove,导致bucket中的Job丢失

hb-chen avatar Aug 27 '19 08:08 hb-chen