awaitTaskToRun()
            } ?: return

          logger.logElapsed(task, task.queue!!) {
            var completedNormally = false
            try {
              runTask(task)
              completedNormally = true
            } finally {
              // If the task is crashing start another thread to service the queues.
              if (!completedNormally) {
                lock.withLock {