private static class SynchronousExecutors.Distributor extends Object implements Runnable
Modifier and Type | Field and Description |
---|---|
private java.util.concurrent.ScheduledExecutorService |
executor |
private java.util.concurrent.locks.Lock |
lock |
private List<Queue<java.util.concurrent.Callable>> |
queues |
private java.util.concurrent.atomic.AtomicBoolean |
waiting |
private java.util.concurrent.locks.Condition |
workToDo |
Constructor and Description |
---|
Distributor(List<Queue<java.util.concurrent.Callable>> queues,
java.util.concurrent.ScheduledExecutorService executor,
java.util.concurrent.locks.Lock lock,
java.util.concurrent.locks.Condition workToDo,
java.util.concurrent.atomic.AtomicBoolean waiting) |
private final List<Queue<java.util.concurrent.Callable>> queues
private final java.util.concurrent.ScheduledExecutorService executor
private final java.util.concurrent.locks.Lock lock
private final java.util.concurrent.locks.Condition workToDo
private final java.util.concurrent.atomic.AtomicBoolean waiting
Distributor(List<Queue<java.util.concurrent.Callable>> queues, java.util.concurrent.ScheduledExecutorService executor, java.util.concurrent.locks.Lock lock, java.util.concurrent.locks.Condition workToDo, java.util.concurrent.atomic.AtomicBoolean waiting)
Copyright 2007-2013, multiple authors.
Licensed under the Apache License, Version 2.0, see the NOTICE file for attributions.