349 lines
12 KiB
Java
349 lines
12 KiB
Java
/*************************************************************************
|
|
*
|
|
* $RCSfile: JavaThreadPool.java,v $
|
|
*
|
|
* $Revision: 1.1.1.1 $
|
|
*
|
|
* last change: $Author: hr $ $Date: 2000-09-18 15:27:52 $
|
|
*
|
|
* The Contents of this file are made available subject to the terms of
|
|
* either of the following licenses
|
|
*
|
|
* - GNU Lesser General Public License Version 2.1
|
|
* - Sun Industry Standards Source License Version 1.1
|
|
*
|
|
* Sun Microsystems Inc., October, 2000
|
|
*
|
|
* GNU Lesser General Public License Version 2.1
|
|
* =============================================
|
|
* Copyright 2000 by Sun Microsystems, Inc.
|
|
* 901 San Antonio Road, Palo Alto, CA 94303, USA
|
|
*
|
|
* This library is free software; you can redistribute it and/or
|
|
* modify it under the terms of the GNU Lesser General Public
|
|
* License version 2.1, as published by the Free Software Foundation.
|
|
*
|
|
* This library is distributed in the hope that it will be useful,
|
|
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
|
|
* Lesser General Public License for more details.
|
|
*
|
|
* You should have received a copy of the GNU Lesser General Public
|
|
* License along with this library; if not, write to the Free Software
|
|
* Foundation, Inc., 59 Temple Place, Suite 330, Boston,
|
|
* MA 02111-1307 USA
|
|
*
|
|
*
|
|
* Sun Industry Standards Source License Version 1.1
|
|
* =================================================
|
|
* The contents of this file are subject to the Sun Industry Standards
|
|
* Source License Version 1.1 (the "License"); You may not use this file
|
|
* except in compliance with the License. You may obtain a copy of the
|
|
* License at http://www.openoffice.org/license.html.
|
|
*
|
|
* Software provided under this License is provided on an "AS IS" basis,
|
|
* WITHOUT WARRANTY OF ANY KIND, EITHER EXPRESSED OR IMPLIED, INCLUDING,
|
|
* WITHOUT LIMITATION, WARRANTIES THAT THE SOFTWARE IS FREE OF DEFECTS,
|
|
* MERCHANTABLE, FIT FOR A PARTICULAR PURPOSE, OR NON-INFRINGING.
|
|
* See the License for the specific provisions governing your rights and
|
|
* obligations concerning the Software.
|
|
*
|
|
* The Initial Developer of the Original Code is: Sun Microsystems, Inc.
|
|
*
|
|
* Copyright: 2000 by Sun Microsystems, Inc.
|
|
*
|
|
* All Rights Reserved.
|
|
*
|
|
* Contributor(s): _______________________________________
|
|
*
|
|
*
|
|
************************************************************************/
|
|
|
|
package com.sun.star.lib.uno.environments.remote;
|
|
|
|
|
|
import java.util.Enumeration;
|
|
import java.util.Hashtable;
|
|
|
|
|
|
import com.sun.star.uno.UnoRuntime;
|
|
|
|
/**
|
|
* This class implements a java thread pool.
|
|
* <p>
|
|
* @version $Revision: 1.1.1.1 $ $ $Date: 2000-09-18 15:27:52 $
|
|
* @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 <code>ThreadID</code> of the given thread.
|
|
* <p>
|
|
* @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 <code>ThreadID</code> of this thread.
|
|
* Implements the method of <code>IThreadPool</code>
|
|
* <p>
|
|
* @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 <code>JobQueue</code> for the given thread under the given <code>ThreadID</code>
|
|
* with the given disposeId.
|
|
* <p>
|
|
* @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);
|
|
|
|
JobQueue jobQueue = (JobQueue)_jobQueues.get(threadId);
|
|
if(jobQueue == null) { // see, if we already have a queue for the given threadId
|
|
synchronized(_jobQueues) {
|
|
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();
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Adds a jobQueue for the current thread to the threadpool.
|
|
* Requests are now put into this queue.
|
|
* Implements the method of <code>IThreadPool</code>
|
|
* <p>
|
|
* @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 <code>JobQueue</code> for the given threadId.
|
|
* <p>
|
|
* @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 <code>JobQueue</code> for the given threadId.
|
|
* <p>
|
|
* @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();
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Removes the jobQueue for the current thread.
|
|
* Implements the method of <code>IThreadPool</code>
|
|
* <p>
|
|
* @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 <code>IThreadPool</code>
|
|
* <p>
|
|
* @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(jobQueue != null)
|
|
removeThread(threadId);
|
|
|
|
// add a new JobQueue for this job
|
|
addThread(true, threadId, disposeId);
|
|
jobQueue = (JobQueue)_jobQueues.get(threadId);
|
|
}
|
|
}
|
|
}
|
|
|
|
jobQueue.putJob(job, disposeId);
|
|
}
|
|
|
|
/**
|
|
* Enters the <code>ThreadPool</code> under the given thread id.
|
|
* Waits for a reply job or an exception.
|
|
* <p>
|
|
* @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 <code>IThreadPool</code>
|
|
* <p>
|
|
* @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 <code>IThreadPool</code>
|
|
* <p>
|
|
* @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)elements.nextElement()).interrupt(disposeId);
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Stops interrupting all jobs queued by the given bridge.
|
|
* Implements the method of <IThreadPool>.
|
|
*/
|
|
public synchronized void stopDispose(Object disposeId) {
|
|
|
|
}
|
|
|
|
synchronized void dispose() {
|
|
if(_disposed) throw new RuntimeException("ThreadPool.dispose - is disposed");
|
|
|
|
_disposed = true;
|
|
|
|
if(_jobQueues.size() > 0)
|
|
System.err.println("Warning! ThreadPool.dipose - there are active JobQueus:" + _jobQueues.size());
|
|
|
|
// clear all jobqueues
|
|
synchronized(_jobQueues) {
|
|
Enumeration elements = _jobQueues.elements();
|
|
while(elements.hasMoreElements())
|
|
((JobQueue)elements.nextElement()).clear();
|
|
|
|
_jobQueues.clear();
|
|
_jobQueues.notifyAll();
|
|
|
|
_jobQueues = null;
|
|
}
|
|
}
|
|
|
|
}
|