corba/src/java.corba/share/classes/com/sun/corba/se/impl/orbutil/threadpool/ThreadPoolImpl.java
changeset 33680 56aa0b79bf5a
parent 29937 c774371adf92
child 37620 230612715768
equal deleted inserted replaced
33559:f242d4332f56 33680:56aa0b79bf5a
    52 import com.sun.corba.se.spi.monitoring.LongMonitoredAttributeBase;
    52 import com.sun.corba.se.spi.monitoring.LongMonitoredAttributeBase;
    53 
    53 
    54 import com.sun.corba.se.impl.logging.ORBUtilSystemException;
    54 import com.sun.corba.se.impl.logging.ORBUtilSystemException;
    55 import com.sun.corba.se.impl.orbutil.ORBConstants;
    55 import com.sun.corba.se.impl.orbutil.ORBConstants;
    56 import com.sun.corba.se.spi.logging.CORBALogDomains;
    56 import com.sun.corba.se.spi.logging.CORBALogDomains;
    57 import com.sun.corba.se.impl.transport.ManagedLocalsThread;
       
    58 
    57 
    59 public class ThreadPoolImpl implements ThreadPool
    58 public class ThreadPoolImpl implements ThreadPool
    60 {
    59 {
    61     // serial counter useful for debugging
    60     // serial counter useful for debugging
    62     private static AtomicInteger threadCounter = new AtomicInteger(0);
    61     private static AtomicInteger threadCounter = new AtomicInteger(0);
   458             availableWorkerThreads++;
   457             availableWorkerThreads++;
   459         }
   458         }
   460     }
   459     }
   461 
   460 
   462 
   461 
   463     private class WorkerThread extends ManagedLocalsThread implements Closeable
   462     private class WorkerThread extends sun.misc.ManagedLocalsThread implements Closeable
   464     {
   463     {
   465         private Work currentWork;
   464         private Work currentWork;
   466         private int threadId = 0; // unique id for the thread
   465         private int threadId = 0; // unique id for the thread
   467         private volatile boolean closeCalled = false;
   466         private volatile boolean closeCalled = false;
   468         private String threadPoolName;
   467         private String threadPoolName;