Class ClientCalls.ThreadlessExecutor

java.lang.Object

java.util.AbstractCollection<Runnable>

java.util.AbstractQueue<Runnable>

java.util.concurrent.ConcurrentLinkedQueue<Runnable>

io.grpc.stub.ClientCalls.ThreadlessExecutor

All Implemented Interfaces:

Serializable, Iterable<Runnable>, Collection<Runnable>, Executor, Queue<Runnable>

Enclosing class:

ClientCalls

private static final class ClientCalls.ThreadlessExecutor
extends ConcurrentLinkedQueue<Runnable>
implements Executor

Field Summary

Fields

Modifier and Type	Field	Description
private static final Logger	log
private static final Object	SHUTDOWN
private Object	waiter

Constructor Summary

Constructors

Constructor	Description
ThreadlessExecutor()

Method Summary

Modifier and Type	Method	Description
void	execute(Runnable runnable)
private static void	runQuietly(Runnable runnable)
void	shutdown()	Called after final call to waitAndDrain(), from same thread.
private static void	throwIfInterrupted()
void	waitAndDrain()	Waits until there is a Runnable, then executes it and all queued Runnables after it.

Methods inherited from class ConcurrentLinkedQueue

add, addAll, contains, isEmpty, iterator, offer, peek, poll, remove, size, spliterator, toArray, toArray

Methods inherited from class AbstractQueue

clear, element, remove

Methods inherited from class AbstractCollection

containsAll, removeAll, retainAll, toString

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface Collection

clear, containsAll, equals, hashCode, parallelStream, removeAll, removeIf, retainAll, stream

Methods inherited from interface Iterable

forEach

Methods inherited from interface Queue

element, remove

Field Details

log

private static final Logger log

SHUTDOWN

private static final Object SHUTDOWN

waiter

private volatile Object waiter

Constructor Details

ThreadlessExecutor

ThreadlessExecutor()

Method Details

waitAndDrain

public void waitAndDrain()
                  throws InterruptedException

Waits until there is a Runnable, then executes it and all queued Runnables after it. Must only be called by one thread at a time.

Throws:

InterruptedException

shutdown

public void shutdown()

Called after final call to waitAndDrain(), from same thread.

runQuietly

private static void runQuietly(Runnable runnable)

throwIfInterrupted

private static void throwIfInterrupted()
                                throws InterruptedException

Throws:

InterruptedException

execute

public void execute(Runnable runnable)

Specified by:

execute in interface Executor