org.apache.geronimo.concurrent.harmony: class: ThreadPoolExecutor.Worker

org.apache.geronimo.concurrent.harmony
class: ThreadPoolExecutor.Worker [javadoc | source]

java.lang.Object
   org.apache.geronimo.concurrent.harmony.ThreadPoolExecutor$Worker

All Implemented Interfaces:
Runnable

Worker threads

Field Summary
volatile long	completedTasks	Per thread completed task counter; accumulated into completedTaskCount upon termination.
Thread	thread	Thread this worker is running in. Acts as a final field, but cannot be set until thread is created.

Constructor:
Worker(Runnable firstTask) { this.firstTask = firstTask; }

Method from org.apache.geronimo.concurrent.harmony.ThreadPoolExecutor$Worker Summary:
interruptIfIdle, interruptNow, isActive, run

Methods from java.lang.Object:
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method from org.apache.geronimo.concurrent.harmony.ThreadPoolExecutor$Worker Detail:
void interruptIfIdle() { final ReentrantLock runLock = this.runLock; if (runLock.tryLock()) { try { thread.interrupt(); } finally { runLock.unlock(); } } } Interrupt thread if not running a task
void interruptNow() { thread.interrupt(); } Cause thread to die even if running a task.
boolean isActive() { return runLock.isLocked(); }
public void run() { try { Runnable task = firstTask; firstTask = null; while (task != null \|\| (task = getTask()) != null) { runTask(task); task = null; // unnecessary but can help GC } } catch(InterruptedException ie) { // fall through } finally { workerDone(this); } } Main run loop

Method from org.apache.geronimo.concurrent.harmony.ThreadPoolExecutor$Worker Detail:

  void interruptIfIdle() {
            final ReentrantLock runLock = this.runLock;
            if (runLock.tryLock()) {
                try {
                    thread.interrupt();
                } finally {
                    runLock.unlock();
                }
            }
}

Interrupt thread if not running a task

  void interruptNow() {
            thread.interrupt();
}

Cause thread to die even if running a task.

 boolean isActive() {
            return runLock.isLocked();
}

 public  void run() {
            try {
                Runnable task = firstTask;
                firstTask = null;
                while (task != null || (task = getTask()) != null) {
                    runTask(task);
                    task = null; // unnecessary but can help GC
                }
            } catch(InterruptedException ie) {
                // fall through
            } finally {
                workerDone(this);
            }
}

Main run loop