* @version $Revision: 1.4 $ $ $Date: 2001-02-28 10:47:01 $
* @author Kay Ramme
* @see com.sun.star.uno.UnoRuntime
* @see com.sun.star.lib.uno.environments.remote.ThreadPool
* @see com.sun.star.lib.uno.environments.remote.IThreadPool
* @see com.sun.star.lib.uno.environments.remote.Job
* @see com.sun.star.lib.uno.environments.remote.JobQueue
* @since UDK1.0
*/
public class JavaThreadPool implements IThreadPool {
/**
* When set to true, enables various debugging output.
*/
public static final boolean DEBUG = false;
protected Hashtable _jobQueues = new Hashtable();
protected Hashtable _disposeIds = new Hashtable();
protected boolean _disposed = false;
/**
* For debugging, lists the jobqueues
*/
synchronized void list() {
Enumeration elements = _jobQueues.keys();
System.err.println("##### ThreadPool.list:");
while(elements.hasMoreElements()) {
System.err.println(" - " + elements.nextElement());
}
}
/**
* Gets the ThreadID of the given thread.
*
* @return the thread id
* @param thread the thread
* @see com.sun.star.lib.uno.environments.remote.ThreadID
*/
static public ThreadID getThreadId(Thread thread) {
ThreadID threadId = null;
if(thread instanceof JobQueue.JobDispatcher)
threadId = ((JobQueue.JobDispatcher)thread).getThreadId();
else
threadId = new ThreadID(UnoRuntime.generateOid(thread).getBytes());
if(DEBUG) System.err.println("##### ThreadPool.getThreadId:" + threadId);
return threadId;
}
/**
* Gets the ThreadID of this thread.
* Implements the method of IThreadPool
*
* @return the thread id
* @see com.sun.star.lib.uno.environments.remote.IThreadPool#getThreadId
*/
public ThreadID getThreadId() {
if(_disposed) throw new RuntimeException("ThreadPool.getThreadId - is disposed");
return getThreadId(Thread.currentThread());
}
/**
* Adds a JobQueue for the given thread under the given ThreadID
* with the given disposeId.
*
* @param createWorkerThread create a JobQueue with or without worker thread
* @param threadId the thread id to use
* @param disposeId the dispose id
*/
public void addThread(boolean createWorkerThread, ThreadID threadId, Object disposeId) throws InterruptedException {
if(_disposed) throw new RuntimeException("ThreadPool.addThread(" + threadId + ") - is disposed");
if(DEBUG) System.err.println("##### ThreadPool.addThread:" + threadId);
synchronized(_jobQueues) {
JobQueue jobQueue = (JobQueue)_jobQueues.get(threadId);
if(jobQueue == null) {
jobQueue = new JobQueue(threadId, createWorkerThread);
_jobQueues.put(threadId, jobQueue);
if(disposeId != null)
_disposeIds.put(threadId, disposeId);
_jobQueues.notifyAll();
}
else
++ jobQueue._add_count;
}
}
/**
* Adds a jobQueue for the current thread to the threadpool.
* Requests are now put into this queue.
* Implements the method of IThreadPool
*
* @param disposeId the dipose id with which the thread can be interrupted while staying in the queue
* @see #enter
* @see com.sun.star.lib.uno.environments.remote.IThreadPool#addThread
*/
public void addThread(Object disposeId) throws InterruptedException {
if(_disposed) throw new RuntimeException("ThreadPool.addThread - is disposed");
addThread(false, getThreadId(Thread.currentThread()), disposeId);
}
/**
* Gives the JobQueue for the given threadId.
*
* @return the job queue
* @param threadId the thread id
* @see com.sun.star.lib.uno.environments.remote.ThreadID
* @see com.sun.star.lib.uno.environments.remote.JobQueue
*/
public JobQueue getJobQueue(ThreadID threadId) {
return (JobQueue)_jobQueues.get(threadId);
}
/**
* Removes the JobQueue for the given threadId.
*
* @param threadId the thread id
* @see com.sun.star.lib.uno.environments.remote.ThreadID
* @see com.sun.star.lib.uno.environments.remote.JobQueue
*/
public void removeThread(ThreadID threadId) {
if(_disposed) throw new RuntimeException("ThreadPool.removeThread - is disposed");
if(DEBUG) System.err.println("##### ThreadPool.removeThread:" + threadId);
JobQueue jobQueue = (JobQueue)_jobQueues.get(threadId);
if(jobQueue != null && jobQueue._add_count <= 0) {
synchronized(_jobQueues) {
if(jobQueue._add_count <= 0) {
_jobQueues.remove(threadId);
_disposeIds.remove(threadId);
_jobQueues.notifyAll();
}
else
-- jobQueue._add_count;
}
}
}
/**
* Removes the jobQueue for the current thread.
* Implements the method of IThreadPool
*
* @see com.sun.star.lib.uno.environments.remote.IThreadPool#removeThread
*/
public void removeThread() {
if(_disposed) throw new RuntimeException("ThreadPool.removeQueue - is disposed");
removeThread(getThreadId());
}
/**
* Queues a job into the jobQueue of the thread belonging to the jobs threadId.
* Implements the method of IThreadPool
*
* @param job the job
* @param disposeId the dispose id
* @see com.sun.star.lib.uno.environments.remote.IThreadPool#putJob
*/
public void putJob(Job job, Object disposeId) throws InterruptedException {
if(_disposed) throw new RuntimeException("ThreadPool.putJob - is disposed");
JobQueue jobQueue = null;
ThreadID threadId = job.getThreadId();
if(DEBUG) System.err.println("#### ThreadPool.putJob:" + threadId + " " + job + " " + _jobQueues);
jobQueue = (JobQueue)_jobQueues.get(threadId);
if(jobQueue == null) {
synchronized(_jobQueues) {
jobQueue = (JobQueue)_jobQueues.get(threadId);
if(jobQueue == null) {
if(job.getOperation() == null) // a reply? and no thread for it?
throw new RuntimeException(getClass().getName() + ".putJob - no thread for reply " + threadId);
// add a new JobQueue for this job
addThread(true, threadId, disposeId);
jobQueue = (JobQueue)_jobQueues.get(threadId);
}
}
}
jobQueue.putJob(job, disposeId);
}
/**
* Enters the ThreadPool under the given thread id.
* Waits for a reply job or an exception.
*
* @result the result of final reply
* @param threadId the thread id to use
*/
public Object enter(ThreadID threadId) throws java.lang.Exception {
if(_disposed) throw new RuntimeException("ThreadPool.enter - is disposed");
JobQueue jobQueue = (JobQueue)_jobQueues.get(threadId);
Object object = null;
try {
object = jobQueue.enter(_disposeIds.get(threadId));
}
finally {
removeThread(threadId);
}
return object;
}
/**
* Lets the current thread enter the ThreadPool.
* The thread then dispatches all jobs and leaves
* the ThreadPool when it gets a reply job.
* Implements the method of IThreadPool
*
* @see com.sun.star.lib.uno.environments.remote.IThreadPool#enter
*/
public Object enter() throws java.lang.Exception {
return enter(getThreadId());
}
/**
* Interrupts all threads which have associated the dispose id.
* Implements the method of IThreadPool
*
* @param disposeId the dispose id
* @see com.sun.star.lib.uno.environments.remote.IThreadPool#dispose
*/
public void dispose(Object disposeId) {
// clear all jobqueues
synchronized(_jobQueues) {
Enumeration elements = _jobQueues.elements();
while(elements.hasMoreElements()) {
JobQueue jobQueue = (JobQueue)elements.nextElement();
jobQueue.interrupt(disposeId);
if(jobQueue._add_count == 0 && jobQueue._createThread) // if the queue already has a count of less zero
_jobQueues.remove(jobQueue.getThreadId());
}
}
}
/**
* Stops interrupting all jobs queued by the given bridge.
* Implements the method of