org.testng.internal.thread

Class ExecutorAdapter

java.lang.Object

java.util.concurrent.AbstractExecutorService

java.util.concurrent.ThreadPoolExecutor

org.testng.internal.thread.ExecutorAdapter

All Implemented Interfaces:

Executor, ExecutorService, IExecutor

public class ExecutorAdapter
extends ThreadPoolExecutor
implements IExecutor

An implementation for IExecutor based on ThreadPoolExecutor

Author:

Nested Class Summary

Nested classes/interfaces inherited from class java.util.concurrent.ThreadPoolExecutor

ThreadPoolExecutor.AbortPolicy, ThreadPoolExecutor.CallerRunsPolicy, ThreadPoolExecutor.DiscardOldestPolicy, ThreadPoolExecutor.DiscardPolicy

Constructor Summary

Constructors

Constructor and Description
ExecutorAdapter(int threadCount, IThreadFactory tf)

Method Summary

Modifier and Type	Method and Description
boolean	awaitTermination(long timeout)
StackTraceElement[][]	getStackTraces()
void	stopNow()
IFutureResult	submitRunnable(Runnable runnable)

Methods inherited from class java.util.concurrent.ThreadPoolExecutor

afterExecute, allowCoreThreadTimeOut, allowsCoreThreadTimeOut, awaitTermination, beforeExecute, execute, finalize, getActiveCount, getCompletedTaskCount, getCorePoolSize, getKeepAliveTime, getLargestPoolSize, getMaximumPoolSize, getPoolSize, getQueue, getRejectedExecutionHandler, getTaskCount, getThreadFactory, isShutdown, isTerminated, isTerminating, prestartAllCoreThreads, prestartCoreThread, purge, remove, setCorePoolSize, setKeepAliveTime, setMaximumPoolSize, setRejectedExecutionHandler, setThreadFactory, shutdown, shutdownNow, terminated, toString

Methods inherited from class java.util.concurrent.AbstractExecutorService

invokeAll, invokeAll, invokeAny, invokeAny, newTaskFor, newTaskFor, submit, submit, submit

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.testng.internal.thread.IExecutor

shutdown

Constructor Detail

ExecutorAdapter

public ExecutorAdapter(int threadCount,
                       IThreadFactory tf)

Method Detail

submitRunnable

public IFutureResult submitRunnable(Runnable runnable)

Specified by:

submitRunnable in interface IExecutor

stopNow

public void stopNow()

Specified by:

stopNow in interface IExecutor

awaitTermination

public boolean awaitTermination(long timeout)

Specified by:

awaitTermination in interface IExecutor

getStackTraces

public StackTraceElement[][] getStackTraces()

Specified by:

getStackTraces in interface IExecutor