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:

java.util.concurrent.Executor, java.util.concurrent.ExecutorService, IExecutor

public class ExecutorAdapter
extends java.util.concurrent.ThreadPoolExecutor
implements IExecutor

An implementation for IExecutor based on ThreadPoolExecutor

Author:

Nested Class Summary

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

java.util.concurrent.ThreadPoolExecutor.AbortPolicy, java.util.concurrent.ThreadPoolExecutor.CallerRunsPolicy, java.util.concurrent.ThreadPoolExecutor.DiscardOldestPolicy, java.util.concurrent.ThreadPoolExecutor.DiscardPolicy

Constructor Summary

ExecutorAdapter(int threadCount, IThreadFactory tf)

Method Summary

boolean	awaitTermination(long timeout)
void	stopNow()
IFutureResult	submitRunnable(java.lang.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

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, toString, 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(java.lang.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