public class LocalTaskQueue<T> extends Object
| Modifier and Type | Field and Description | 
|---|---|
| static int | MAX_SIZE | 
| static Object | NO_MORE_TASKS | 
| Constructor and Description | 
|---|
| LocalTaskQueue() | 
| Modifier and Type | Method and Description | 
|---|---|
| void | closeInput()Synchronized (logical) insert of a NO_MORE_TASKS symbol at the end of the FIFO queue in order to
 mark that no more tasks will be inserted into the queue. | 
| T | dequeueTask()Synchronized read and delete from the top of the FIFO queue. | 
| void | enqueueTask(T t)Synchronized insert of a new task to the end of the FIFO queue. | 
| String | toString() | 
public static final int MAX_SIZE
public static final Object NO_MORE_TASKS
public void enqueueTask(T t) throws InterruptedException
t - taskInterruptedException - if InterruptedException occurspublic T dequeueTask() throws InterruptedException
InterruptedException - if InterruptedException occurspublic void closeInput()
Copyright © 2020 The Apache Software Foundation. All rights reserved.