包子求endless.com 20% off coupon one time use# Fashion - 美丽时尚
j*t
1 楼
一个queue里会有很多很多future, 包括future放进来的时间。要求一个处理这个queue
的thread,(也可以多个)凡事超过一定时间的都认为time out, 要invoke other
function 重新处理。做完的要record 做完了就行了。没做完的,但没超时接着等。
我觉得既然这样就肯定不能用future.get (timeout).
我只能不停的检查queue, 看每个future.isdone, 和future产生的时间,做完的和超
时的处理好说,但是没做完的还得放回来。但是如果只有一两个job的话还没time out
的话,就会不停的dequque, enqueue. 显然会waste a lot of computer power,
问问大牛有什么更好的方法吗?
的thread,(也可以多个)凡事超过一定时间的都认为time out, 要invoke other
function 重新处理。做完的要record 做完了就行了。没做完的,但没超时接着等。
我觉得既然这样就肯定不能用future.get (timeout).
我只能不停的检查queue, 看每个future.isdone, 和future产生的时间,做完的和超
时的处理好说,但是没做完的还得放回来。但是如果只有一两个job的话还没time out
的话,就会不停的dequque, enqueue. 显然会waste a lot of computer power,
问问大牛有什么更好的方法吗?