co.paralleluniverse.fibers

Class FiberForkJoinScheduler

java.lang.Object

co.paralleluniverse.fibers.FiberScheduler

co.paralleluniverse.fibers.FiberForkJoinScheduler

All Implemented Interfaces:

FiberFactory, StrandFactory

public class FiberForkJoinScheduler
extends FiberScheduler

A ForkJoinPool based scheduler for fibers.

Constructor Summary

Constructors

Constructor and Description
FiberForkJoinScheduler(java.lang.String name, int parallelism) Creates a new fiber scheduler using a default UncaughtExceptionHandler and no monitoring.
FiberForkJoinScheduler(java.lang.String name, int parallelism, MonitorType monitorType, boolean detailedInfo) Creates a new fiber scheduler using a default UncaughtExceptionHandler.
FiberForkJoinScheduler(java.lang.String name, int parallelism, java.lang.Thread.UncaughtExceptionHandler exceptionHandler, MonitorType monitorType, boolean detailedInfo) Creates a new fiber scheduler.

Method Summary

Modifier and Type	Method and Description
java.util.concurrent.Executor	getExecutor()
java.util.concurrent.ForkJoinPool	getForkJoinPool()
protected int	getQueueLength()
protected boolean	isCurrentThreadInScheduler()
static boolean	isFiberThread(java.lang.Thread t)
protected void	onIdle()
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

FiberForkJoinScheduler

public FiberForkJoinScheduler(java.lang.String name,
                              int parallelism,
                              java.lang.Thread.UncaughtExceptionHandler exceptionHandler,
                              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.

parallelism - the number of threads in the pool

exceptionHandler - an UncaughtExceptionHandler to be used for exceptions thrown in fibers that aren't caught.

monitorType - the MonitorType type to use for the ForkJoinPool.

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

FiberForkJoinScheduler

public FiberForkJoinScheduler(java.lang.String name,
                              int parallelism,
                              MonitorType monitorType,
                              boolean detailedInfo)

Creates a new fiber scheduler using a default UncaughtExceptionHandler.

Parameters:

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

parallelism - the number of threads in the pool

monitorType - the MonitorType type to use for the ForkJoinPool.

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

FiberForkJoinScheduler

public FiberForkJoinScheduler(java.lang.String name,
                              int parallelism)

Creates a new fiber scheduler using a default UncaughtExceptionHandler and no monitoring.

Parameters:

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

parallelism - the number of threads in the pool

Method Detail

shutdown

public void shutdown()

Overrides:

shutdown in class FiberScheduler

getForkJoinPool

public java.util.concurrent.ForkJoinPool getForkJoinPool()

getExecutor

public java.util.concurrent.Executor getExecutor()

Specified by:

getExecutor in class FiberScheduler

getQueueLength

protected int getQueueLength()

Specified by:

getQueueLength in class FiberScheduler

isCurrentThreadInScheduler

protected final boolean isCurrentThreadInScheduler()

Specified by:

isCurrentThreadInScheduler in class FiberScheduler

isFiberThread

public static boolean isFiberThread(java.lang.Thread t)

onIdle

protected void onIdle()