- private final int maxQueueLength;
- private ArrayDeque<Runnable> disposerQueue = new ArrayDeque<Runnable>(MAX_QUEUE_LENGTH);
- private TObjectLongHashMap<Runnable> disposeTime =
- new TObjectLongHashMap<Runnable>(MAX_QUEUE_LENGTH);
+ private volatile int maxQueueLength;
+ private ArrayDeque<Runnable> disposerQueue;
+ private TObjectLongHashMap<Runnable> disposeTime;