Package org.openhab.core.util

Class SameThreadExecutorService

java.lang.Object

java.util.concurrent.AbstractExecutorService

org.openhab.core.util.SameThreadExecutorService

All Implemented Interfaces:

AutoCloseable, Executor, ExecutorService, ScheduledExecutorService

@NonNullByDefault
public class SameThreadExecutorService
extends AbstractExecutorService
implements ScheduledExecutorService

ExecutorService implementation that runs all tasks in the calling thread in order to enable deterministic testing.

Not for use outside tests

Author:

David Pace - Initial contribution, Ravi Nadahar - Adapted for more general use

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected static class	SameThreadExecutorService.ImpostorScheduledFuture<T>	A ScheduledFuture that wraps a Future and always reports zero delay.

Field Summary

Fields

Modifier and Type	Field	Description
protected boolean	terminated

Constructor Summary

Constructors

Constructor	Description
SameThreadExecutorService()

Method Summary

Modifier and Type	Method	Description
boolean	awaitTermination(long timeout, @Nullable TimeUnit unit)
void	execute(@Nullable Runnable command)
boolean	isShutdown()
boolean	isTerminated()
ScheduledFuture<?>	schedule(@Nullable Runnable command, long delay, @Nullable TimeUnit unit)	Not supported if delay is non-zero.
<V> ScheduledFuture<V>	schedule(@Nullable Callable<V> callable, long delay, @Nullable TimeUnit unit)	Not supported if delay is non-zero.
ScheduledFuture<?>	scheduleAtFixedRate(@Nullable Runnable task, long initialDelay, long period, @Nullable TimeUnit unit)	Will execute immediately and run only once.
ScheduledFuture<?>	scheduleWithFixedDelay(@Nullable Runnable task, long initialDelay, long delay, @Nullable TimeUnit unit)	Will execute immediately and run only once.
void	shutdown()
List<Runnable>	shutdownNow()
Future<?>	submit(@Nullable Runnable task)
<T> Future<T>	submit(@Nullable Runnable task, @Nullable T result)
<T> Future<T>	submit(@Nullable Callable<T> task)

Methods inherited from class java.util.concurrent.AbstractExecutorService

invokeAll, invokeAll, invokeAny, invokeAny, newTaskFor, newTaskFor

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.concurrent.ExecutorService

close, invokeAll, invokeAll, invokeAny, invokeAny

Field Details

terminated

protected volatile boolean terminated

Constructor Details

SameThreadExecutorService

public SameThreadExecutorService()

Method Details

shutdown

public void shutdown()

Specified by:

shutdown in interface ExecutorService

shutdownNow

@NonNullByDefault({})
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,
 @Nullable TimeUnit unit)
                         throws InterruptedException

Specified by:

awaitTermination in interface ExecutorService

Throws:

InterruptedException

execute

public void execute(@Nullable Runnable command)

Specified by:

execute in interface Executor

submit

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

Specified by:

submit in interface ExecutorService

Overrides:

submit in class AbstractExecutorService

submit

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

Specified by:

submit in interface ExecutorService

Overrides:

submit in class AbstractExecutorService

submit

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

Specified by:

submit in interface ExecutorService

Overrides:

submit in class AbstractExecutorService

schedule

public ScheduledFuture<?> schedule(@Nullable Runnable command,
 long delay,
 @Nullable TimeUnit unit)

Not supported if delay is non-zero.

Specified by:

schedule in interface ScheduledExecutorService

Throws:

NullPointerException - if command is null.

UnsupportedOperationException - if delay is non-zero.

schedule

public <V> ScheduledFuture<V> schedule(@Nullable Callable<V> callable,
 long delay,
 @Nullable TimeUnit unit)

Not supported if delay is non-zero.

Specified by:

schedule in interface ScheduledExecutorService

Throws:

NullPointerException - if callable is null.

UnsupportedOperationException - if delay is non-zero.

scheduleAtFixedRate

public ScheduledFuture<?> scheduleAtFixedRate(@Nullable Runnable task,
 long initialDelay,
 long period,
 @Nullable TimeUnit unit)

Will execute immediately and run only once.

Specified by:

scheduleAtFixedRate in interface ScheduledExecutorService

scheduleWithFixedDelay

public ScheduledFuture<?> scheduleWithFixedDelay(@Nullable Runnable task,
 long initialDelay,
 long delay,
 @Nullable TimeUnit unit)

Will execute immediately and run only once.

Specified by:

scheduleWithFixedDelay in interface ScheduledExecutorService