Package org.mpi_sws.jmc.api.util.concurrent

Class JmcExecutorService

java.lang.Object

org.mpi_sws.jmc.api.util.concurrent.JmcExecutorService

All Implemented Interfaces:

AutoCloseable, Executor, ExecutorService

public class JmcExecutorService
extends Object
implements ExecutorService

An executor service that runs tasks in new threads. It is a redefinition of ExecutorService for JMC model checking.

Currently, the executor service does not support stopping tasks.

Constructor Summary

Constructors

Constructor	Description
JmcExecutorService(int capacity)

Method Summary

Modifier and Type	Method	Description
boolean	awaitTermination(long l, TimeUnit timeUnit)	Waits for the executor service to terminate.
void	execute(Runnable runnable)
<T> List<Future<T>>	invokeAll(Collection<? extends Callable<T>> collection)
<T> List<Future<T>>	invokeAll(Collection<? extends Callable<T>> collection, long l, TimeUnit timeUnit)
<T> T	invokeAny(Collection<? extends Callable<T>> collection)
<T> T	invokeAny(Collection<? extends Callable<T>> collection, long l, TimeUnit timeUnit)
boolean	isShutdown()	Returns whether the executor service is shutdown.
boolean	isTerminated()	Returns whether the executor service is terminated.
void	shutdown()	Stops the executor service.
List<Runnable>	shutdownNow()	Stops the executor service.
JmcFuture<?>	submit(Runnable runnable)
<T> JmcFuture<T>	submit(Runnable runnable, T t)
<T> JmcFuture<T>	submit(Callable<T> callable)	Submits a callable task to the executor service.

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

Constructor Details

JmcExecutorService

public JmcExecutorService(int capacity)

Method Details

shutdown

public void shutdown()

Stops the executor service.

Specified by:

shutdown in interface ExecutorService

shutdownNow

public List<Runnable> shutdownNow()

Stops the executor service. Currently not supported.

Specified by:

shutdownNow in interface ExecutorService

isShutdown

public boolean isShutdown()

Returns whether the executor service is shutdown.

Specified by:

isShutdown in interface ExecutorService

isTerminated

public boolean isTerminated()

Returns whether the executor service is terminated.

Specified by:

isTerminated in interface ExecutorService

awaitTermination

public boolean awaitTermination(long l,
 TimeUnit timeUnit)
                         throws InterruptedException

Waits for the executor service to terminate.

Specified by:

awaitTermination in interface ExecutorService

Throws:

InterruptedException

submit

public <T> JmcFuture<T> submit(Callable<T> callable)

Submits a callable task to the executor service.

Specified by:

submit in interface ExecutorService

submit

public <T> JmcFuture<T> submit(Runnable runnable,
 T t)

Specified by:

submit in interface ExecutorService

submit

public JmcFuture<?> submit(Runnable runnable)

Specified by:

submit in interface ExecutorService

invokeAll

public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> collection)
                              throws InterruptedException

Specified by:

invokeAll in interface ExecutorService

Throws:

InterruptedException

invokeAll

public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> collection,
 long l,
 TimeUnit timeUnit)
                              throws InterruptedException

Specified by:

invokeAll in interface ExecutorService

Throws:

InterruptedException

invokeAny

public <T> T invokeAny(Collection<? extends Callable<T>> collection)
                throws InterruptedException,
ExecutionException

Specified by:

invokeAny in interface ExecutorService

Throws:

InterruptedException

ExecutionException

invokeAny

public <T> T invokeAny(Collection<? extends Callable<T>> collection,
 long l,
 TimeUnit timeUnit)
                throws InterruptedException,
ExecutionException,
TimeoutException

Specified by:

invokeAny in interface ExecutorService

Throws:

InterruptedException

ExecutionException

TimeoutException

execute

public void execute(Runnable runnable)

Specified by:

execute in interface Executor