new ThreadPool interface (#87110#)

2 files changed, 364 insertions, 0 deletions

diff --git a/jurt/com/sun/star/lib/uno/environments/remote/JavaThreadPoolFactory.java b/jurt/com/sun/star/lib/uno/environments/remote/JavaThreadPoolFactory.java
new file mode 100644
index 000000000000..05885e0d6ef7
--- /dev/null
+++ b/jurt/com/sun/star/lib/uno/environments/remote/JavaThreadPoolFactory.java
@@ -0,0 +1,190 @@
+/*************************************************************************
+ *
+ *  $RCSfile: JavaThreadPoolFactory.java,v $
+ *
+ *  $Revision: 1.1 $
+ *
+ *  last change: $Author: kr $ $Date: 2001-05-17 12:42:21 $
+ *
+ *  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.io.UnsupportedEncodingException;
+
+import java.util.Enumeration;
+import java.util.Hashtable;
+
+
+import com.sun.star.uno.UnoRuntime;
+
+
+public class JavaThreadPoolFactory implements IThreadPoolFactory {
+    private static final boolean DEBUG = false;
+
+    protected Hashtable _jobQueues  = new Hashtable();
+
+
+//      public JavaThreadPoolFactory() {
+//          new Thread() {
+//                  public void run() {
+//                      try {
+//                          while(true) {
+//                              list();
+
+//                              Thread.sleep(2000);
+//                          }
+//                      }
+//                      catch(InterruptedException interruptedException) {
+//                          System.err.println("lister interrupted:" + interruptedException);
+//                      }
+//                  }
+//              }.start();
+//      }
+
+
+    /**
+     * For debugging, lists the jobqueues
+     */
+    synchronized void list() {
+        Enumeration elements = _jobQueues.elements();
+
+        System.err.println("##### JavaThreadPoolFactory.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
+     */
+    public ThreadId getThreadId(Thread thread) {
+        ThreadId threadId = null;
+
+        if(thread instanceof JobQueue.JobDispatcher)
+            threadId = ((JobQueue.JobDispatcher)thread).getThreadId();
+        else {
+            try {
+                threadId = new ThreadId(UnoRuntime.generateOid(thread).getBytes("UTF8"));
+            }
+            catch(UnsupportedEncodingException unsupportedEncodingException) {
+                throw new com.sun.star.uno.RuntimeException("JavaThreadPool.getThreadId - unexpected: " + unsupportedEncodingException.toString());
+            }
+        }
+
+        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() {
+        return getThreadId(Thread.currentThread());
+    }
+
+
+    void addJobQueue(JobQueue jobQueue) {
+        if(DEBUG) System.err.println("##### "+ getClass().getName() + ".addJobQueue:" + jobQueue + " " + ((jobQueue._sync_jobQueue != null) ? jobQueue._sync_jobQueue._threadId : null));
+
+        _jobQueues.put(jobQueue.getThreadId(), jobQueue);
+    }
+
+    JobQueue getJobQueue(ThreadId threadId) {
+        return (JobQueue)_jobQueues.get(threadId);
+    }
+
+    void removeJobQueue(JobQueue jobQueue) {
+        _jobQueues.remove(jobQueue.getThreadId());
+    }
+
+
+    JobQueue getAsyncJobQueue(ThreadId threadId) {
+        JobQueue jobQueue = (JobQueue)_jobQueues.get(threadId);
+
+        JobQueue async_jobQueue = null;
+
+        if(jobQueue != null)
+            async_jobQueue = jobQueue._async_jobQueue;
+
+        if(DEBUG) System.err.println("##### "+ getClass().getName() + ".getAsyncJobQueue:" + jobQueue + " " + async_jobQueue);
+
+        return async_jobQueue;
+    }
+
+    public IThreadPool createThreadPool() {
+        return new JavaThreadPool(this);
+    }
+
+    void dispose(Object disposeId, Throwable throwable) {
+        Enumeration elements = _jobQueues.elements();
+
+        while(elements.hasMoreElements())
+            ((JobQueue)elements.nextElement()).dispose(disposeId, throwable);
+    }
+}
diff --git a/jurt/com/sun/star/lib/uno/environments/remote/ThreadId.java b/jurt/com/sun/star/lib/uno/environments/remote/ThreadId.java
new file mode 100644
index 000000000000..48b5c9b3004f
--- /dev/null
+++ b/jurt/com/sun/star/lib/uno/environments/remote/ThreadId.java
@@ -0,0 +1,174 @@
+/*************************************************************************
+ *
+ *  $RCSfile: ThreadId.java,v $
+ *
+ *  $Revision: 1.1 $
+ *
+ *  last change: $Author: kr $ $Date: 2001-05-17 12:44:32 $
+ *
+ *  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.io.UnsupportedEncodingException;
+
+
+import com.sun.star.uno.UnoRuntime;
+
+
+
+/**
+ * This is the global thread id.
+ * <p>
+ * @version     $Revision: 1.1 $ $ $Date: 2001-05-17 12:44:32 $
+ * @author      Joerg Budischewski
+ * @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
+ */
+public class ThreadId {
+    static protected byte __async_count;
+
+    protected byte   _threadId[];
+    protected int    _hashCode;
+    protected String _string;
+
+
+    /**
+     * Constructs a new thread id
+     * <p>
+     */
+    public ThreadId() {
+        try {
+            init(UnoRuntime.generateOid(new Object()).getBytes("UTF8"));
+        }
+        catch(UnsupportedEncodingException unsupportedEncodingException) {
+            throw new com.sun.star.uno.RuntimeException(getClass().getName() + ".<init> - unexpected: " + unsupportedEncodingException.toString());
+        }
+    }
+
+    /**
+     * Constructs a new thread id from the given byte array
+     * <p>
+     * @param  threadID     a byte array describing a thread id
+     */
+    public ThreadId(byte threadId[]) {
+        init(threadId);
+    }
+
+    /**
+     * Initializes a thread id with a byte array
+     * <p>
+     * @param  threadID     a byte array describing a thread id
+     */
+    private void init(byte threadId[]) {
+        try {
+            _threadId = threadId;
+              _string = new String(threadId, "8859_1");
+        }
+        catch(java.io.UnsupportedEncodingException bla) {
+            System.err.println(getClass().getName() + ".init - unexpected exception:" + bla);
+        }
+    }
+
+    /**
+     * Gives a hashcode.
+     * <p>
+     */
+    public int hashCode() {
+        //              return _hashCode;
+          return _string.hashCode();
+    }
+
+    /**
+     * Gives a thread id described by a byte array
+     * <p>
+     * @return   a byte array
+     */
+    public byte[] getBytes() {
+        return _threadId;
+    }
+
+    /**
+     * Indicates whether two thread ids describe the same threadid
+     * <p>
+     * @return   <code>true</code>, if the thread ids are equal
+     * @param   othreadID    the other thread id
+     */
+    public boolean equals(Object othreadId) {
+          return _string.equals(((ThreadId)othreadId)._string);
+    }
+
+    /**
+     * Gives a descriptive string
+     * <p>
+     * @return   the descriptive string
+     */
+    public String toString() {
+        String result = "id:";
+
+        for(int i = 0; i < _threadId.length; ++ i) {
+            String tmp = Integer.toHexString(_threadId[i]);
+            if(tmp.length() < 2)
+                result += "0" + tmp;
+            else
+                result += tmp.substring(tmp.length() - 2);
+        }
+
+        return result;
+    }
+}
+
+