if (!tasks.offer(task)) {
    throw new RejectedExecutionException("back-pressured?");
}
if (!running) {
    lock.lock();
    try {
        condition.signal();
    } finally {
        lock.unlock();
    }
}
return null;