org.testng.internal.thread
Class ExecutorAdapter

java.lang.Object
  extended by java.util.concurrent.AbstractExecutorService
      extended by java.util.concurrent.ThreadPoolExecutor
          extended by 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


Copyright © 2010. All Rights Reserved.