akka.dispatch

Class MonitorableThreadFactory

java.lang.Object

akka.dispatch.MonitorableThreadFactory

All Implemented Interfaces:

java.io.Serializable, java.util.concurrent.ForkJoinPool.ForkJoinWorkerThreadFactory, java.util.concurrent.ThreadFactory, scala.Equals, scala.Product

public final class MonitorableThreadFactory
extends java.lang.Object
implements java.util.concurrent.ThreadFactory, java.util.concurrent.ForkJoinPool.ForkJoinWorkerThreadFactory, scala.Product, scala.Serializable

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	MonitorableThreadFactory.AkkaForkJoinWorkerThread

Constructor Summary

Constructors

Constructor and Description
MonitorableThreadFactory(java.lang.String name, boolean daemonic, scala.Option<java.lang.ClassLoader> contextClassLoader, java.lang.Thread.UncaughtExceptionHandler exceptionHandler, java.util.concurrent.atomic.AtomicLong counter)

Method Summary

Modifier and Type	Method and Description
abstract static boolean	canEqual(java.lang.Object that)
scala.Option<java.lang.ClassLoader>	contextClassLoader()
protected java.util.concurrent.atomic.AtomicLong	counter()
boolean	daemonic()
static java.lang.Thread.UncaughtExceptionHandler	doNothing()
abstract static boolean	equals(java.lang.Object that)
java.lang.Thread.UncaughtExceptionHandler	exceptionHandler()
java.lang.String	name()
java.util.concurrent.ForkJoinWorkerThread	newThread(java.util.concurrent.ForkJoinPool pool)
java.lang.Thread	newThread(java.lang.Runnable runnable)
abstract static int	productArity()
abstract static java.lang.Object	productElement(int n)
static scala.collection.Iterator<java.lang.Object>	productIterator()
static java.lang.String	productPrefix()
protected <T extends java.lang.Thread> T	wire(T t)
MonitorableThreadFactory	withName(java.lang.String newName)

Methods inherited from class java.lang.Object

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

Methods inherited from interface scala.Product

$init$, productArity, productElement, productIterator, productPrefix

Methods inherited from interface scala.Equals

canEqual, equals

Constructor Detail

MonitorableThreadFactory

public MonitorableThreadFactory(java.lang.String name,
                                boolean daemonic,
                                scala.Option<java.lang.ClassLoader> contextClassLoader,
                                java.lang.Thread.UncaughtExceptionHandler exceptionHandler,
                                java.util.concurrent.atomic.AtomicLong counter)

Method Detail

doNothing

public static java.lang.Thread.UncaughtExceptionHandler doNothing()

canEqual

public abstract static boolean canEqual(java.lang.Object that)

equals

public abstract static boolean equals(java.lang.Object that)

productElement

public abstract static java.lang.Object productElement(int n)

productArity

public abstract static int productArity()

productIterator

public static scala.collection.Iterator<java.lang.Object> productIterator()

productPrefix

public static java.lang.String productPrefix()

name

public java.lang.String name()

daemonic

public boolean daemonic()

contextClassLoader

public scala.Option<java.lang.ClassLoader> contextClassLoader()

exceptionHandler

public java.lang.Thread.UncaughtExceptionHandler exceptionHandler()

counter

protected java.util.concurrent.atomic.AtomicLong counter()

newThread

public java.util.concurrent.ForkJoinWorkerThread newThread(java.util.concurrent.ForkJoinPool pool)

Specified by:

newThread in interface java.util.concurrent.ForkJoinPool.ForkJoinWorkerThreadFactory

newThread

public java.lang.Thread newThread(java.lang.Runnable runnable)

Specified by:

newThread in interface java.util.concurrent.ThreadFactory

withName

public MonitorableThreadFactory withName(java.lang.String newName)

wire

protected <T extends java.lang.Thread> T wire(T t)