co.paralleluniverse.fibers

Class FiberTimedScheduler

java.lang.Object

co.paralleluniverse.fibers.FiberTimedScheduler

public class FiberTimedScheduler
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
FiberTimedScheduler(FiberScheduler scheduler)
FiberTimedScheduler(FiberScheduler scheduler, FibersMonitor monitor)
FiberTimedScheduler(FiberScheduler scheduler, java.util.concurrent.ThreadFactory threadFactory, FibersMonitor monitor)

Method Summary

Modifier and Type	Method and Description
boolean	awaitTermination(long timeout, java.util.concurrent.TimeUnit unit)
void	finalize()
int	getQueueLength()
boolean	isShutdown()
boolean	isTerminated()
protected void	reject(java.lang.Object command)
java.util.concurrent.Future<java.lang.Void>	schedule(Fiber<?> fiber, java.lang.Object blocker, long delay, java.util.concurrent.TimeUnit unit)
void	shutdown() Initiates an orderly shutdown in which previously submitted tasks are executed, but no new tasks will be accepted.
void	shutdownNow() Attempts to stop all actively executing tasks, halts the processing of waiting tasks, and returns a list of the tasks that were awaiting execution.

Methods inherited from class java.lang.Object

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

Constructor Detail

FiberTimedScheduler

public FiberTimedScheduler(FiberScheduler scheduler,
                           java.util.concurrent.ThreadFactory threadFactory,
                           FibersMonitor monitor)

FiberTimedScheduler

public FiberTimedScheduler(FiberScheduler scheduler,
                           FibersMonitor monitor)

FiberTimedScheduler

public FiberTimedScheduler(FiberScheduler scheduler)

Method Detail

schedule

public java.util.concurrent.Future<java.lang.Void> schedule(Fiber<?> fiber,
                                                            java.lang.Object blocker,
                                                            long delay,
                                                            java.util.concurrent.TimeUnit unit)

getQueueLength

public int getQueueLength()

reject

protected void reject(java.lang.Object command)

shutdown

public void shutdown()

Initiates an orderly shutdown in which previously submitted tasks are executed, but no new tasks will be accepted. Invocation has no additional effect if already shut down.

This method does not wait for previously submitted tasks to complete execution. Use awaitTermination to do that.

If the ExecuteExistingDelayedTasksAfterShutdownPolicy has been set false, existing delayed tasks whose delays have not yet elapsed are cancelled. And unless the ContinueExistingPeriodicTasksAfterShutdownPolicy has been set true, future executions of existing periodic tasks will be cancelled.

finalize

public void finalize()
              throws java.lang.Throwable

Overrides:

finalize in class java.lang.Object

Throws:

java.lang.Throwable

shutdownNow

public void shutdownNow()

Attempts to stop all actively executing tasks, halts the processing of waiting tasks, and returns a list of the tasks that were awaiting execution.

This method does not wait for actively executing tasks to terminate. Use awaitTermination to do that.

There are no guarantees beyond best-effort attempts to stop processing actively executing tasks. This implementation cancels tasks via Thread.interrupt(), so any task that fails to respond to interrupts may never terminate.

awaitTermination

public boolean awaitTermination(long timeout,
                                java.util.concurrent.TimeUnit unit)
                         throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException

isShutdown

public boolean isShutdown()

isTerminated

public boolean isTerminated()