DwAsyncPoolImpl

java.lang.Object
- net.datenwerke.async.DwAsyncPoolImpl

All Implemented Interfaces:: DwAsyncPool

public class DwAsyncPoolImpl
extends java.lang.Object
implements DwAsyncPool

Default implementation of DwAsyncPool

Constructor Summary

Constructors
Constructor and Description
`DwAsyncPoolImpl(DwThreadPoolExecutor executorService)` Creates a new thread pool from the given executor.
`DwAsyncPoolImpl(java.lang.String threadLabel)` Creates a new pool with the given label.

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`boolean`	`awaitTermination(long timeout, java.util.concurrent.TimeUnit unit)` Blocks until all tasks have completed execution after a shutdown request, or the timeout occurs, or the current thread is interrupted, whichever happens first.
`int`	`getActiveCount()` Returns the approximate number of threads that are actively executing tasks.
`long`	`getCompletedTaskCount()` Returns the approximate total number of tasks that have completed execution.
`int`	`getCorePoolSize()` Returns the core number of threads.
`java.util.concurrent.ExecutorService`	`getExecutorService()` Returns the underlying `ExecutorService` object.
`int`	`getPoolSize()` Returns the current number of threads in the pool.
`long`	`getTaskCount()` Returns the approximate total number of tasks that have ever been scheduled for execution.
`boolean`	`isShutdown()` Returns true if the pool has been shut down (orderly).
`boolean`	`isTerminated()` Returns true if the pool has been terminated
`void`	`shutdown()` Initiates an orderly shutdown in which previously submitted tasks are executed, but no new tasks will be accepted.
`java.util.List<java.lang.Runnable>`	`shutdownNow()` Attempts to stop all actively executing tasks, halts the processing of waiting tasks, and returns a list of the tasks that were awaiting execution.
`<T> java.util.concurrent.Future<T>`	`submit(java.util.concurrent.Callable<T> task)` Submits a value-returning task for execution and returns a Future representing the pending results of the task.
`java.util.concurrent.Future<?>`	`submit(java.lang.Runnable task)` Submits a Runnable task for execution and returns a Future representing that task.
`<T> java.util.concurrent.Future<T>`	`submit(java.lang.Runnable task, T result)` Submits a Runnable task for execution and returns a Future representing that task.

Methods inherited from class java.lang.Object
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Constructor Detail
  - DwAsyncPoolImpl
```
public DwAsyncPoolImpl(java.lang.String threadLabel)
```
    Creates a new pool with the given label. The pool will be created as a ThreadPoolFactory.newCachedThreadPool(String).
    
    Parameters:
    
    threadLabel -
    
    See Also:
    
    ThreadPoolFactory.newCachedThreadPool(String)
  - DwAsyncPoolImpl
```
public DwAsyncPoolImpl(DwThreadPoolExecutor executorService)
```
    Creates a new thread pool from the given executor.
    
    Parameters:
    
    executorService -
- Method Detail
  - submit
```
public <T> java.util.concurrent.Future<T> submit(java.util.concurrent.Callable<T> task)
```
    Description copied from interface: DwAsyncPool
    
    Submits a value-returning task for execution and returns a Future representing the pending results of the task. The Future's get method will return the task's result upon successful completion.
    
    Specified by:
    
    submit in interface DwAsyncPool
    
    See Also:
    
    ExecutorService.submit(Callable)
  - submit
```
public java.util.concurrent.Future<?> submit(java.lang.Runnable task)
```
    Description copied from interface: DwAsyncPool
    
    Submits a Runnable task for execution and returns a Future representing that task. The Future's get method will return null upon successful completion.
    
    Specified by:
    
    submit in interface DwAsyncPool
    
    See Also:
    
    ExecutorService.submit(Runnable)
  - submit
```
public <T> java.util.concurrent.Future<T> submit(java.lang.Runnable task,
                                                 T result)
```
    Description copied from interface: DwAsyncPool
    
    Submits a Runnable task for execution and returns a Future representing that task. The Future's get method will return the given result upon successful completion.
    
    Specified by:
    
    submit in interface DwAsyncPool
    
    See Also:
    
    ExecutorService.submit(Runnable, Object)
  - awaitTermination
```
public boolean awaitTermination(long timeout,
                                java.util.concurrent.TimeUnit unit)
                         throws java.lang.InterruptedException
```
    Description copied from interface: DwAsyncPool
    
    Blocks until all tasks have completed execution after a shutdown request, or the timeout occurs, or the current thread is interrupted, whichever happens first.
    
    Specified by:
    
    awaitTermination in interface DwAsyncPool
    
    Throws:
    
    java.lang.InterruptedException
    
    See Also:
    
    ExecutorService.awaitTermination(long, TimeUnit)
  - getExecutorService
```
public java.util.concurrent.ExecutorService getExecutorService()
```
    Returns the underlying ExecutorService object.
  - getActiveCount
```
public int getActiveCount()
```
    Description copied from interface: DwAsyncPool
    
    Returns the approximate number of threads that are actively executing tasks.
    
    Specified by:
    
    getActiveCount in interface DwAsyncPool
    
    Returns:
    
    the number of threads
    
    See Also:
    
    ThreadPoolExecutor.getActiveCount()
  - getPoolSize
```
public int getPoolSize()
```
    Description copied from interface: DwAsyncPool
    
    Returns the current number of threads in the pool.
    
    Specified by:
    
    getPoolSize in interface DwAsyncPool
    
    Returns:
    
    the number of threads
    
    See Also:
    
    ThreadPoolExecutor.getPoolSize()
  - getCorePoolSize
```
public int getCorePoolSize()
```
    Description copied from interface: DwAsyncPool
    
    Returns the core number of threads.
    
    Specified by:
    
    getCorePoolSize in interface DwAsyncPool
    
    Returns:
    
    the core number of threads
    
    See Also:
    
    ThreadPoolExecutor.getCorePoolSize()
  - getTaskCount
```
public long getTaskCount()
```
    Description copied from interface: DwAsyncPool
    
    Returns the approximate total number of tasks that have ever been scheduled for execution. Because the states of tasks and threads may change dynamically during computation, the returned value is only an approximation.
    
    Specified by:
    
    getTaskCount in interface DwAsyncPool
    
    Returns:
    
    the number of threads
    
    See Also:
    
    ThreadPoolExecutor.getTaskCount()
  - getCompletedTaskCount
```
public long getCompletedTaskCount()
```
    Description copied from interface: DwAsyncPool
    
    Returns the approximate total number of tasks that have completed execution. Because the states of tasks and threads may change dynamically during computation, the returned value is only an approximation, but one that does not ever decrease across successive calls.
    
    Specified by:
    
    getCompletedTaskCount in interface DwAsyncPool
    
    Returns:
    
    the number of threads
    
    See Also:
    
    ThreadPoolExecutor.getCompletedTaskCount()
  - isShutdown
```
public boolean isShutdown()
```
    Description copied from interface: DwAsyncPool
    
    Returns true if the pool has been shut down (orderly).
    
    Specified by:
    
    isShutdown in interface DwAsyncPool
  - isTerminated
```
public boolean isTerminated()
```
    Description copied from interface: DwAsyncPool
    
    Returns true if the pool has been terminated
    
    Specified by:
    
    isTerminated in interface DwAsyncPool
  - shutdown
```
public void shutdown()
```
    Description copied from interface: DwAsyncPool
    
    Initiates an orderly shutdown in which previously submitted tasks are executed, but no new tasks will be accepted. Invocation has no additional effect if already shut down.
    This method does not wait for previously submitted tasks to complete execution. Use awaitTermination to do that.
    
    Specified by:
    
    shutdown in interface DwAsyncPool
    
    See Also:
    
    ExecutorService.shutdown()
  - shutdownNow
```
public java.util.List<java.lang.Runnable> shutdownNow()
```
    Description copied from interface: DwAsyncPool
    
    Attempts to stop all actively executing tasks, halts the processing of waiting tasks, and returns a list of the tasks that were awaiting execution.
    This method does not wait for actively executing tasks to terminate. Use awaitTermination to do that.
    There are no guarantees beyond best-effort attempts to stop processing actively executing tasks. For example, typical implementations will cancel via Thread.interrupt(), so any task that fails to respond to interrupts may never terminate.
    
    Specified by:
    
    shutdownNow in interface DwAsyncPool
    
    Returns:
    
    list of tasks that never commenced execution
    
    See Also:
    
    ExecutorService.shutdownNow()

Class DwAsyncPoolImpl

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Constructor Detail

DwAsyncPoolImpl

DwAsyncPoolImpl

Method Detail

submit

submit

submit

awaitTermination

getExecutorService

getActiveCount

getPoolSize

getCorePoolSize

getTaskCount

getCompletedTaskCount

isShutdown

isTerminated

shutdown

shutdownNow