Package com.sap.cloud.sdk.cloudplatform.thread

Class DefaultThreadContextExecutorService

java.lang.Object

com.sap.cloud.sdk.cloudplatform.thread.DefaultThreadContextExecutorService

All Implemented Interfaces:

ThreadContextExecutorService, Executor, ExecutorService

public final class DefaultThreadContextExecutorService
extends Object
implements ThreadContextExecutorService

This class represents the default implementation of ThreadContextExecutorService.

Method Summary

Modifier and Type	Method	Description
boolean	awaitTermination(long timeout, TimeUnit unit)
void	execute(Runnable command)
void	execute(Runnable command, ThreadContext threadContext)	Attach a ThreadContext to the given command and execute it.
void	execute(Runnable command, ThreadContextExecutor threadContextExecutor)	Attach a ThreadContextExecutor to the given command and execute it.
<T> List<Future<T>>	invokeAll(Collection<? extends Callable<T>> tasks)
<T> List<Future<T>>	invokeAll(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit)
<T> T	invokeAny(Collection<? extends Callable<T>> tasks)
<T> T	invokeAny(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit)
boolean	isShutdown()
boolean	isTerminated()
static DefaultThreadContextExecutorService	of(ExecutorService executorService)	Static factory method that enables the given ExecutorService to attach a ThreadContext to its tasks.
void	shutdown()
List<Runnable>	shutdownNow()
Future<?>	submit(Runnable task)
Future<?>	submit(Runnable task, ThreadContext threadContext)	Attach a ThreadContext to the given task and execute it.
Future<?>	submit(Runnable task, ThreadContextExecutor threadContextExecutor)	Attach a ThreadContextExecutor to the given task and execute it.
<T> Future<T>	submit(Runnable task, T result)
<T> Future<T>	submit(Runnable task, T result, ThreadContext threadContext)	Attach a ThreadContext to the given task and execute it.
<T> Future<T>	submit(Runnable task, T result, ThreadContextExecutor threadContextExecutor)	Attach a ThreadContextExecutor to the given task and execute it.
<T> Future<T>	submit(Callable<T> task)
<T> Future<T>	submit(Callable<T> task, ThreadContext threadContext)	Attach a ThreadContext to the given task and execute it.
<T> Future<T>	submit(Callable<T> task, ThreadContextExecutor threadContextExecutor)	Attach a ThreadContextExecutor to the given task and execute it.

Methods inherited from class java.lang.Object

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

Method Details

of

@Nonnull
public static DefaultThreadContextExecutorService of(@Nonnull
 ExecutorService executorService)

Static factory method that enables the given ExecutorService to attach a ThreadContext to its tasks. The properties will be inherited only if the current parent Thread contains a ThreadContext.

Parameters:

executorService - The executor service instance.

Returns:

The customized executor service.

execute

public void execute(@Nonnull
 Runnable command)

Specified by:

execute in interface Executor

execute

public void execute(@Nonnull
 Runnable command,
 @Nonnull
 ThreadContext threadContext)

Description copied from interface: ThreadContextExecutorService

Attach a ThreadContext to the given command and execute it.

Specified by:

execute in interface ThreadContextExecutorService

Parameters:

command - the runnable task

threadContext - the ThreadContext to attach to the command

See Also:

• Executor.execute(Runnable)

execute

public void execute(@Nonnull
 Runnable command,
 @Nonnull
 ThreadContextExecutor threadContextExecutor)

Description copied from interface: ThreadContextExecutorService

Attach a ThreadContextExecutor to the given command and execute it.

Specified by:

execute in interface ThreadContextExecutorService

Parameters:

command - the runnable task

threadContextExecutor - the ThreadContextExecutor to attach to the command

See Also:

• Executor.execute(Runnable)

shutdown

public void shutdown()

Specified by:

shutdown in interface ExecutorService

shutdownNow

@Nonnull
public List<Runnable> shutdownNow()

Specified by:

shutdownNow in interface ExecutorService

isShutdown

public boolean isShutdown()

Specified by:

isShutdown in interface ExecutorService

isTerminated

public boolean isTerminated()

Specified by:

isTerminated in interface ExecutorService

awaitTermination

public boolean awaitTermination(long timeout,
 @Nonnull
 TimeUnit unit)
                         throws InterruptedException

Specified by:

awaitTermination in interface ExecutorService

Throws:

InterruptedException

submit

@Nonnull
public <T> Future<T> submit(@Nonnull
 Callable<T> task)

Specified by:

submit in interface ExecutorService

submit

@Nonnull
public <T> Future<T> submit(@Nonnull
 Callable<T> task,
 @Nonnull
 ThreadContext threadContext)

Description copied from interface: ThreadContextExecutorService

Attach a ThreadContext to the given task and execute it.

Specified by:

submit in interface ThreadContextExecutorService

Type Parameters:

T - the type of the task's result

Parameters:

task - the task to submit

threadContext - the ThreadContext to attach to the task

Returns:

a Future representing pending completion of the task

See Also:

• ExecutorService.submit(Callable)

submit

@Nonnull
public <T> Future<T> submit(@Nonnull
 Callable<T> task,
 @Nonnull
 ThreadContextExecutor threadContextExecutor)

Description copied from interface: ThreadContextExecutorService

Attach a ThreadContextExecutor to the given task and execute it.

Specified by:

submit in interface ThreadContextExecutorService

Type Parameters:

T - the type of the task's result

Parameters:

task - the task to submit

threadContextExecutor - the ThreadContextExecutor to attach to the task

Returns:

a Future representing pending completion of the task

See Also:

• ExecutorService.submit(Callable)

submit

@Nonnull
public <T> Future<T> submit(@Nonnull
 Runnable task,
 @Nonnull
 T result)

Specified by:

submit in interface ExecutorService

submit

@Nonnull
public <T> Future<T> submit(@Nonnull
 Runnable task,
 @Nonnull
 T result,
 @Nonnull
 ThreadContext threadContext)

Description copied from interface: ThreadContextExecutorService

Attach a ThreadContext to the given task and execute it.

Specified by:

submit in interface ThreadContextExecutorService

Type Parameters:

T - the type of the task's result

Parameters:

task - the task to submit

result - the result to return

threadContext - the ThreadContext to attach to the task

Returns:

a Future representing pending completion of the task

See Also:

• ExecutorService.submit(Runnable, Object)

submit

@Nonnull
public <T> Future<T> submit(@Nonnull
 Runnable task,
 @Nonnull
 T result,
 @Nonnull
 ThreadContextExecutor threadContextExecutor)

Description copied from interface: ThreadContextExecutorService

Attach a ThreadContextExecutor to the given task and execute it.

Specified by:

submit in interface ThreadContextExecutorService

Type Parameters:

T - the type of the task's result

Parameters:

task - the task to submit

result - the result to return

threadContextExecutor - the ThreadContextExecutor to attach to the task

Returns:

a Future representing pending completion of the task

See Also:

• ExecutorService.submit(Runnable, Object)

submit

@Nonnull
public Future<?> submit(@Nonnull
 Runnable task)

Specified by:

submit in interface ExecutorService

submit

@Nonnull
public Future<?> submit(@Nonnull
 Runnable task,
 @Nonnull
 ThreadContext threadContext)

Description copied from interface: ThreadContextExecutorService

Attach a ThreadContext to the given task and execute it.

Specified by:

submit in interface ThreadContextExecutorService

Parameters:

task - the task to submit

threadContext - the ThreadContext to attach to the task

Returns:

a Future representing pending completion of the task

See Also:

• ExecutorService.submit(Runnable)

submit

@Nonnull
public Future<?> submit(@Nonnull
 Runnable task,
 @Nonnull
 ThreadContextExecutor threadContextExecutor)

Description copied from interface: ThreadContextExecutorService

Attach a ThreadContextExecutor to the given task and execute it.

Specified by:

submit in interface ThreadContextExecutorService

Parameters:

task - the task to submit

threadContextExecutor - the ThreadContextExecutor to attach to the task

Returns:

a Future representing pending completion of the task

See Also:

• ExecutorService.submit(Runnable)

invokeAll

@Nonnull
public <T> List<Future<T>> invokeAll(@Nonnull
 Collection<? extends Callable<T>> tasks)
                              throws InterruptedException

Specified by:

invokeAll in interface ExecutorService

Throws:

InterruptedException

invokeAll

@Nonnull
public <T> List<Future<T>> invokeAll(@Nonnull
 Collection<? extends Callable<T>> tasks,
 long timeout,
 @Nonnull
 TimeUnit unit)
                              throws InterruptedException

Specified by:

invokeAll in interface ExecutorService

Throws:

InterruptedException

invokeAny

@Nonnull
public <T> T invokeAny(@Nonnull
 Collection<? extends Callable<T>> tasks)
                throws InterruptedException,
ExecutionException

Specified by:

invokeAny in interface ExecutorService

Throws:

InterruptedException

ExecutionException

invokeAny

@Nonnull
public <T> T invokeAny(@Nonnull
 Collection<? extends Callable<T>> tasks,
 long timeout,
 @Nonnull
 TimeUnit unit)
                throws InterruptedException,
ExecutionException,
TimeoutException

Specified by:

invokeAny in interface ExecutorService

Throws:

InterruptedException

ExecutionException

TimeoutException