7b4c3c7bb1
There appears to be an intermittent NPE in queue tests relating to the deferred shutdown/terminate functions. This PR more formally asserts that shutdown and termination occurs before starting and finishing the tests but leaves the defer in place to ensure that if there is an issue shutdown/termination will occur. Signed-off-by: Andrew Thornton <art27@cantab.net> |
||
---|---|---|
.. | ||
bytefifo.go | ||
helper.go | ||
manager.go | ||
queue.go | ||
queue_bytefifo.go | ||
queue_channel.go | ||
queue_channel_test.go | ||
queue_disk.go | ||
queue_disk_channel.go | ||
queue_disk_channel_test.go | ||
queue_disk_test.go | ||
queue_redis.go | ||
queue_test.go | ||
queue_wrapped.go | ||
setting.go | ||
unique_queue.go | ||
unique_queue_channel.go | ||
unique_queue_channel_test.go | ||
unique_queue_disk.go | ||
unique_queue_disk_channel.go | ||
unique_queue_redis.go | ||
unique_queue_wrapped.go | ||
workerpool.go |