co.paralleluniverse.fibers

Class FiberExecutorScheduler

java.lang.Object

co.paralleluniverse.fibers.FiberScheduler

co.paralleluniverse.fibers.FiberExecutorScheduler

All Implemented Interfaces:

FiberFactory, StrandFactory, java.util.concurrent.Executor

public class FiberExecutorScheduler
extends FiberScheduler
implements java.util.concurrent.Executor

A fiber scheduler that uses a given Executor for scheduling. The Runnable tasks passed to the Executor for execution, implement the FiberSchedulerTask interface.

Constructor Summary

Constructors

Constructor and Description
FiberExecutorScheduler(java.lang.String name, java.util.concurrent.Executor executor) Creates a new fiber scheduler with no monitor.
FiberExecutorScheduler(java.lang.String name, java.util.concurrent.Executor executor, MonitorType monitorType, boolean detailedInfo) Creates a new fiber scheduler.

Method Summary

Modifier and Type	Method and Description
void	execute(java.lang.Runnable command)
java.util.concurrent.Executor	getExecutor()
protected int	getQueueLength()
protected java.util.Map<java.lang.Thread,Fiber>	getRunningFibers()
protected boolean	isCurrentThreadInScheduler()
void	shutdown()

Methods inherited from class co.paralleluniverse.fibers.FiberScheduler

getMonitor, getName, newFiber, newStrand

Methods inherited from class java.lang.Object

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

Constructor Detail

FiberExecutorScheduler

public FiberExecutorScheduler(java.lang.String name,
                              java.util.concurrent.Executor executor,
                              MonitorType monitorType,
                              boolean detailedInfo)

Creates a new fiber scheduler.

Parameters:

name - the scheuler's name. This name is used in naming the scheduler's threads.

executor - an Executor used to schedule the fibers; may be null if the execute(Runnable) method is overriden.

monitorType - the MonitorType type to use for the scheduler.

detailedInfo - whether detailed information about the fibers is collected by the fibers monitor.

FiberExecutorScheduler

public FiberExecutorScheduler(java.lang.String name,
                              java.util.concurrent.Executor executor)

Creates a new fiber scheduler with no monitor.

Parameters:

name - the scheuler's name. This name is used in naming the scheduler's threads.

executor - an Executor used to schedule the fibers; may be null if the execute(Runnable) method is overriden.

Method Detail

shutdown

public void shutdown()

Overrides:

shutdown in class FiberScheduler

isCurrentThreadInScheduler

protected boolean isCurrentThreadInScheduler()

Specified by:

isCurrentThreadInScheduler in class FiberScheduler

getQueueLength

protected int getQueueLength()

Specified by:

getQueueLength in class FiberScheduler

execute

public void execute(java.lang.Runnable command)

Specified by:

execute in interface java.util.concurrent.Executor

getRunningFibers

protected java.util.Map<java.lang.Thread,Fiber> getRunningFibers()

getExecutor

public java.util.concurrent.Executor getExecutor()

Specified by:

getExecutor in class FiberScheduler