alluxio.master.transport

Class GrpcMessagingContext

java.lang.Object

alluxio.master.transport.GrpcMessagingContext

public class GrpcMessagingContext
extends Object

The context for Grpc messaging single thread. This context uses a ScheduledExecutorService to schedule events on the context thread.

Constructor Summary

Constructors

Constructor and Description
GrpcMessagingContext(GrpcMessagingThreadFactory factory, io.atomix.catalyst.serializer.Serializer serializer) Constructs a new single thread GrpcMessagingContext.
GrpcMessagingContext(ScheduledExecutorService executor, io.atomix.catalyst.serializer.Serializer serializer) Constructs a new single thread GrpcMessagingContext.
GrpcMessagingContext(String nameFormat, io.atomix.catalyst.serializer.Serializer serializer) Constructs a new GrpcMessagingContext.
GrpcMessagingContext(Thread thread, ScheduledExecutorService executor, io.atomix.catalyst.serializer.Serializer serializer) Constructs a new GrpcMessagingContext.

Method Summary

Modifier and Type	Method and Description
void	close() Closes the context.
CompletableFuture<Void>	execute(Runnable callback) Executes the given callback.
<T> CompletableFuture<T>	execute(java.util.function.Supplier<T> callback) Executes the given callback.
Executor	executor()
protected static GrpcMessagingThread	getThread(ExecutorService executor) Gets the thread from a single threaded executor service.
org.apache.http.concurrent.Cancellable	schedule(java.time.Duration delay, java.time.Duration interval, Runnable runnable) Submits a one-shot task that becomes enabled after the given delay.
org.apache.http.concurrent.Cancellable	schedule(java.time.Duration delay, Runnable runnable) Submits a one-shot task that becomes enabled after the given delay.
io.atomix.catalyst.serializer.Serializer	serializer()

Methods inherited from class java.lang.Object

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

Constructor Detail

GrpcMessagingContext

public GrpcMessagingContext(String nameFormat,
                            io.atomix.catalyst.serializer.Serializer serializer)

Constructs a new GrpcMessagingContext.

Parameters:

nameFormat - the name format used when instantiating the context thread

serializer - the context serializer

GrpcMessagingContext

public GrpcMessagingContext(GrpcMessagingThreadFactory factory,
                            io.atomix.catalyst.serializer.Serializer serializer)

Constructs a new single thread GrpcMessagingContext.

Parameters:

factory - factory to use when creating the new thread

serializer - the serializer

GrpcMessagingContext

public GrpcMessagingContext(ScheduledExecutorService executor,
                            io.atomix.catalyst.serializer.Serializer serializer)

Constructs a new single thread GrpcMessagingContext.

Parameters:

executor - the single thread scheduled executor to schedule events on

serializer - the serializer

GrpcMessagingContext

public GrpcMessagingContext(Thread thread,
                            ScheduledExecutorService executor,
                            io.atomix.catalyst.serializer.Serializer serializer)

Constructs a new GrpcMessagingContext.

Parameters:

thread - the thread

executor - the executor

serializer - the serializer

Method Detail

getThread

protected static GrpcMessagingThread getThread(ExecutorService executor)

Gets the thread from a single threaded executor service.

serializer

public io.atomix.catalyst.serializer.Serializer serializer()

Returns:

the serializer of this context

executor

public Executor executor()

Returns:

the executor of this context

schedule

public org.apache.http.concurrent.Cancellable schedule(java.time.Duration delay,
                                                       Runnable runnable)

Submits a one-shot task that becomes enabled after the given delay.

Parameters:

delay - the time from now to delay execution

runnable - the task to execute

Returns:

task cancellable

schedule

public org.apache.http.concurrent.Cancellable schedule(java.time.Duration delay,
                                                       java.time.Duration interval,
                                                       Runnable runnable)

Submits a one-shot task that becomes enabled after the given delay.

Parameters:

delay - the time from now to delay execution

interval - the interval between successive executions

runnable - the task to execute

Returns:

task cancellable

close

public void close()

Closes the context.

execute

public CompletableFuture<Void> execute(Runnable callback)

Executes the given callback.

Parameters:

callback - the callback to execute

Returns:

completable future of the callback run

execute

public <T> CompletableFuture<T> execute(java.util.function.Supplier<T> callback)

Executes the given callback.

Type Parameters:

T - the supplier type

Parameters:

callback - the callback to execute

Returns:

completable future of the callback run