org.jdiameter.common.impl.concurrent
Class ConcurrentEntityFactory

java.lang.Object
  org.jdiameter.common.impl.concurrent.ConcurrentEntityFactory

All Implemented Interfaces:

IConcurrentEntityFactory

public class ConcurrentEntityFactory
extends java.lang.Object
implements IConcurrentEntityFactory

Author:

Alexandre Mendonca , Bartosz Baranowski

Constructor Summary

ConcurrentEntityFactory()

Method Summary

<L> java.util.concurrent.Callable<L>	newDefaultCallable(java.util.concurrent.Callable<L> runnable, IStatistic statistic, IStatisticRecord... statisticRecords)
java.lang.Runnable	newDefaultRunnable(java.lang.Runnable runnable, IStatistic statistic, IStatisticRecord... statisticRecords)
java.util.concurrent.RejectedExecutionHandler	newRejectedExecutionHandler(IStatisticRecord rejectedCount)
java.util.concurrent.ThreadFactory	newThreadFactory(java.lang.String threadPoolName)

Methods inherited from class java.lang.Object

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

Constructor Detail

ConcurrentEntityFactory

public ConcurrentEntityFactory()

Method Detail

newThreadFactory

public java.util.concurrent.ThreadFactory newThreadFactory(java.lang.String threadPoolName)

Specified by:

newThreadFactory in interface IConcurrentEntityFactory

newRejectedExecutionHandler

public java.util.concurrent.RejectedExecutionHandler newRejectedExecutionHandler(IStatisticRecord rejectedCount)

Specified by:

newRejectedExecutionHandler in interface IConcurrentEntityFactory

newDefaultCallable

public <L> java.util.concurrent.Callable<L> newDefaultCallable(java.util.concurrent.Callable<L> runnable,
                                                               IStatistic statistic,
                                                               IStatisticRecord... statisticRecords)

Specified by:

newDefaultCallable in interface IConcurrentEntityFactory

newDefaultRunnable

public java.lang.Runnable newDefaultRunnable(java.lang.Runnable runnable,
                                             IStatistic statistic,
                                             IStatisticRecord... statisticRecords)

Specified by:

newDefaultRunnable in interface IConcurrentEntityFactory