public class ConcurrentExecutor extends Object implements Executor
ConcurrentExecutor
object is used to execute tasks
in a thread pool. This creates a thread pool with an unbounded list
of outstanding tasks, which ensures that any system requesting
a task to be executed will not block when handing it over.Constructor and Description |
---|
ConcurrentExecutor(Class type)
Constructor for the
ConcurrentExecutor object. |
ConcurrentExecutor(Class type,
int size)
Constructor for the
ConcurrentExecutor object. |
ConcurrentExecutor(Class type,
int rest,
int active)
Constructor for the
ConcurrentExecutor object. |
Modifier and Type | Method and Description |
---|---|
void |
execute(Runnable task)
The
execute method is used to queue the task for
execution. |
void |
stop()
This is used to stop the executor by interrupting all running
tasks and shutting down the threads within the pool.
|
void |
stop(long wait)
This is used to stop the executor by interrupting all running
tasks and shutting down the threads within the pool.
|
public ConcurrentExecutor(Class type)
ConcurrentExecutor
object. This
is used to create a pool of threads that can be used to execute
arbitrary Runnable
tasks. If the threads are
busy this will simply enqueue the tasks and return.type
- this is the type of runnable that this acceptspublic ConcurrentExecutor(Class type, int size)
ConcurrentExecutor
object. This
is used to create a pool of threads that can be used to execute
arbitrary Runnable
tasks. If the threads are
busy this will simply enqueue the tasks and return.type
- this is the type of runnable that this acceptssize
- this is the number of threads to use in the poolpublic ConcurrentExecutor(Class type, int rest, int active)
ConcurrentExecutor
object. This
is used to create a pool of threads that can be used to execute
arbitrary Runnable
tasks. If the threads are
busy this will simply enqueue the tasks and return.type
- this is the type of runnable that this acceptsrest
- this is the number of threads to use in the poolactive
- this is the maximum size the pool can grow topublic void execute(Runnable task)
execute
method is used to queue the task for
execution. If all threads are busy the provided task is queued
and waits until all current and outstanding tasks are finished.public void stop()
public void stop(long wait)
wait
- the number of milliseconds to wait for it to stopCopyright © 2021. All rights reserved.