corba/src/java.corba/share/classes/com/sun/corba/se/impl/orbutil/threadpool/ThreadPoolImpl.java
equal
deleted
inserted
replaced
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; |