org.compass.core.executor.spi
Interface InternalExecutorManager

All Known Subinterfaces:
ExecutorManager
All Known Implementing Classes:
ConcurrentExecutorManager, DefaultExecutorManager, ScheduledExecutorManager, WorkManagerExecutorManager, WorkManagerExecutorManager

public interface InternalExecutorManager

An executor manager is an abstraction on top of async and scheduled execution of tasks.

Author:
kimchy

Method Summary
 void close()
          Shuts down this executor manager.
<T> List<Future<T>>
invokeAll(Collection<Callable<T>> tasks)
           
<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)
           
<T> Future<T>
submit(Callable<T> task)
           
 void submit(Runnable task)
           
 

Method Detail

submit

void submit(Runnable task)
See Also:
ExecutorService.submit(Runnable)

submit

<T> Future<T> submit(Callable<T> task)
See Also:
ExecutorService.submit(java.util.concurrent.Callable)

invokeAll

<T> List<Future<T>> invokeAll(Collection<Callable<T>> tasks)
                          throws InterruptedException
Throws:
InterruptedException
See Also:
ExecutorService.invokeAll(java.util.Collection)

schedule

<V> ScheduledFuture<V> schedule(Callable<V> callable,
                                long delay,
                                TimeUnit unit)
See Also:
ScheduledExecutorService.schedule(java.util.concurrent.Callable, long, java.util.concurrent.TimeUnit)

scheduleAtFixedRate

ScheduledFuture<?> scheduleAtFixedRate(Runnable command,
                                       long initialDelay,
                                       long period,
                                       TimeUnit unit)
See Also:
ScheduledExecutorService.scheduleAtFixedRate(Runnable, long, long, java.util.concurrent.TimeUnit)

scheduleWithFixedDelay

ScheduledFuture<?> scheduleWithFixedDelay(Runnable command,
                                          long initialDelay,
                                          long delay,
                                          TimeUnit unit)
See Also:
ScheduledExecutorService.scheduleWithFixedDelay(Runnable, long, long, java.util.concurrent.TimeUnit)

close

void close()
Shuts down this executor manager.



Copyright (c) 2004-2009 The Compass Project.