ColumnWorker.close() returns early when the calling thread is interrupted, leaving decode tasks running