Adding a 'drain' method for long-running queues (so the final queue does not silently consume all memory).