Package org.ros.concurrent

Class SharedScheduledExecutorService

java.lang.Object

org.ros.concurrent.SharedScheduledExecutorService

All Implemented Interfaces:

Executor, ExecutorService, ScheduledExecutorService

public class SharedScheduledExecutorService
extends Object
implements ScheduledExecutorService

A ScheduledExecutorService which cannot be shut down. This can be safely injected into instances which should not be in control of the ExecutorService's lifecycle.

Author:

khughes@google.com (Keith M. Hughes)

Constructor Summary

Constructors

Constructor	Description
SharedScheduledExecutorService(ScheduledExecutorService wrapped)

Method Summary

Modifier and Type	Method	Description
boolean	awaitTermination(long timeout, TimeUnit unit)
void	execute(Runnable command)
<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()
ScheduledFuture<?>	schedule(Runnable command, long delay, TimeUnit unit)
<V> ScheduledFuture<V>	schedule(Callable<V> callable, long delay, TimeUnit unit)
ScheduledFuture<?>	scheduleAtFixedRate(Runnable command, long initialDelay, long period, TimeUnit unit)
ScheduledFuture<?>	scheduleWithFixedDelay(Runnable command, long initialDelay, long delay, TimeUnit unit)
void	shutdown()
List<Runnable>	shutdownNow()
Future<?>	submit(Runnable task)
<T> Future<T>	submit(Runnable task, T result)
<T> Future<T>	submit(Callable<T> task)

Methods inherited from class java.lang.Object

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

Constructor Details

SharedScheduledExecutorService

public SharedScheduledExecutorService(ScheduledExecutorService wrapped)

Method Details

awaitTermination

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

Specified by:

awaitTermination in interface ExecutorService

Throws:

InterruptedException

See Also:

• ExecutorService.awaitTermination(long, java.util.concurrent.TimeUnit)

execute

public void execute(Runnable command)

Specified by:

execute in interface Executor

Parameters:

command -

See Also:

• Executor.execute(java.lang.Runnable)

invokeAll

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

Specified by:

invokeAll in interface ExecutorService

Throws:

InterruptedException

See Also:

• ExecutorService.invokeAll(java.util.Collection, long, java.util.concurrent.TimeUnit)

invokeAll

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

Specified by:

invokeAll in interface ExecutorService

Throws:

InterruptedException

See Also:

• ExecutorService.invokeAll(java.util.Collection)

invokeAny

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

Specified by:

invokeAny in interface ExecutorService

Throws:

InterruptedException

ExecutionException

TimeoutException

See Also:

• ExecutorService.invokeAny(java.util.Collection, long, java.util.concurrent.TimeUnit)

invokeAny

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

Specified by:

invokeAny in interface ExecutorService

Throws:

InterruptedException

ExecutionException

See Also:

• ExecutorService.invokeAny(java.util.Collection)

isShutdown

public boolean isShutdown()

Specified by:

isShutdown in interface ExecutorService

See Also:

• ExecutorService.isShutdown()

isTerminated

public boolean isTerminated()

Specified by:

isTerminated in interface ExecutorService

See Also:

• ExecutorService.isTerminated()

schedule

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

Specified by:

schedule in interface ScheduledExecutorService

See Also:

• ScheduledExecutorService.schedule(java.util.concurrent.Callable, long, java.util.concurrent.TimeUnit)

schedule

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

Specified by:

schedule in interface ScheduledExecutorService

See Also:

• ScheduledExecutorService.schedule(java.lang.Runnable, long, java.util.concurrent.TimeUnit)

scheduleAtFixedRate

public ScheduledFuture<?> scheduleAtFixedRate(Runnable command,
 long initialDelay,
 long period,
 TimeUnit unit)

Specified by:

scheduleAtFixedRate in interface ScheduledExecutorService

See Also:

• ScheduledExecutorService.scheduleAtFixedRate(java.lang.Runnable, long, long, java.util.concurrent.TimeUnit)

scheduleWithFixedDelay

public ScheduledFuture<?> scheduleWithFixedDelay(Runnable command,
 long initialDelay,
 long delay,
 TimeUnit unit)

Specified by:

scheduleWithFixedDelay in interface ScheduledExecutorService

See Also:

• ScheduledExecutorService.scheduleWithFixedDelay(java.lang.Runnable, long, long, java.util.concurrent.TimeUnit)

shutdown

public void shutdown()

Specified by:

shutdown in interface ExecutorService

See Also:

• ExecutorService.shutdown()

shutdownNow

public List<Runnable> shutdownNow()

Specified by:

shutdownNow in interface ExecutorService

See Also:

• ExecutorService.shutdownNow()

submit

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

Specified by:

submit in interface ExecutorService

See Also:

• ExecutorService.submit(java.util.concurrent.Callable)

submit

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

Specified by:

submit in interface ExecutorService

See Also:

• ExecutorService.submit(java.lang.Runnable, java.lang.Object)

submit

public Future<?> submit(Runnable task)

Specified by:

submit in interface ExecutorService

See Also:

• ExecutorService.submit(java.lang.Runnable)