} catch (InterruptedException e) {
throw new RuntimeException(e);
}
}
public void schedule(BiConsumer<Backend, Consumer<Backend>> annotate) {
<BUG>queueLock.lock();
</BUG>
try {
queue.add(annotate);
enqueued.signal();

} catch (InterruptedException e) {
throw new RuntimeException(e);
}
}
public void schedule(BiConsumer<Backend, Consumer<Backend>> annotate) {
stateLock.lock();
try {
queue.add(annotate);
enqueued.signal();
