public final class ThreadPool
extends java.lang.Object
Modifier and Type | Class and Description |
---|---|
private class |
ThreadPool.ThreadPoolRequest |
private class |
ThreadPool.ThreadPoolThread |
Modifier and Type | Field and Description |
---|---|
private CondVar |
cvAvailable |
private CondVar |
cvEmpty |
private BusyFlag |
cvFlag |
private int |
nMaxThreads |
private int |
nObjects |
private java.util.Vector |
objects |
private ThreadPool.ThreadPoolThread[] |
poolThreads |
private boolean |
terminated |
Constructor and Description |
---|
ThreadPool(java.lang.String name,
int m_maxConcurrentThreads) |
ThreadPool(java.lang.String name,
int n,
int priority) |
Modifier and Type | Method and Description |
---|---|
private void |
add(java.lang.Runnable target,
java.lang.Object lock) |
void |
addRequest(java.lang.Runnable target) |
void |
addRequestAndWait(java.lang.Runnable target) |
void |
shutdown() |
private java.util.Vector objects
private int nObjects
private int nMaxThreads
private CondVar cvAvailable
private CondVar cvEmpty
private BusyFlag cvFlag
private ThreadPool.ThreadPoolThread[] poolThreads
private boolean terminated
public ThreadPool(java.lang.String name, int m_maxConcurrentThreads)
public ThreadPool(java.lang.String name, int n, int priority)
public void shutdown()
private void add(java.lang.Runnable target, java.lang.Object lock)
public void addRequest(java.lang.Runnable target)
public void addRequestAndWait(java.lang.Runnable target) throws java.lang.InterruptedException
java.lang.InterruptedException
Copyright © 2023. All rights reserved.