com.viaoa.concurrent

Class OAExecutorService

java.lang.Object

com.viaoa.concurrent.OAExecutorService

public class OAExecutorService
extends Object

creates an ExecutorService to await commands to run.

Author:

vvia

Constructor Summary

Constructors

Constructor and Description
OAExecutorService()
OAExecutorService(int size, String name)
OAExecutorService(String name)

Method Summary

Modifier and Type	Method and Description
void	close()
int	getActiveThreads()
ExecutorService	getExecutorService()
int	getQueueSize() number of elements in the queue waiting on thread to pick it up.
int	getThreadPoolSize()
static void	main(String[] args)
Future	submit(Callable c)
Future	submit(Runnable r)
Future	submitAndWait(Callable c, int maxWait, TimeUnit tu)
Future	submitAndWait(Runnable r, int maxWait, TimeUnit tu)

Methods inherited from class java.lang.Object

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

Constructor Detail

OAExecutorService

public OAExecutorService()

OAExecutorService

public OAExecutorService(String name)

OAExecutorService

public OAExecutorService(int size,
                         String name)

Method Detail

submit

public Future submit(Runnable r)

submitAndWait

public Future submitAndWait(Runnable r,
                            int maxWait,
                            TimeUnit tu)
                     throws Exception

Throws:

Exception

submit

public Future submit(Callable c)

submitAndWait

public Future submitAndWait(Callable c,
                            int maxWait,
                            TimeUnit tu)
                     throws Exception

Throws:

Exception

close

public void close()

getExecutorService

public ExecutorService getExecutorService()

getQueueSize

public int getQueueSize()

number of elements in the queue waiting on thread to pick it up.

getThreadPoolSize

public int getThreadPoolSize()

getActiveThreads

public int getActiveThreads()

main

public static void main(String[] args)
                 throws Exception

Throws:

Exception