All Packages  This Package  Class Hierarchy  Class Search  Index

java.lang.Object
   |
   +----edu.utah.janos.nodeos.ThreadPool

Summary

public final class  ThreadPool
     extends java.lang.Object
{
          // Fields 5
     private boolean destroyed;
     private Flow flow;
     private WorkItem head;
     private WorkItem tail;
     private final Object workLock;

          // Constructors 1
     public ThreadPool(Flow, Object, ThreadScheduler);

          // Methods 9
     void addWork(WorkItem);
     WorkItem dequeueWorkItem();
     public void destroy();
     public boolean destroyed();
     void doWork();
     void enqueueWorkItem(WorkItem);
     public Flow getFlow();
     void signalWorkers();
     public Thread threadStart(Runnable);
}

ThreadPool wrapper for Java.

Author:

Janos Ministry of Development

Cross Reference

Returned By:

Flow.threadPool()

   private final Object workLock

Lock protecting the queue of WorkItems.

   private WorkItem head

WorkItems are added here.

   private WorkItem tail

WorkItems are removed here.

   private Flow flow

   private boolean destroyed

Constructors

· ThreadPool

Summary  |  Top

   public ThreadPool(Flow flow, 
                     Object variousSchedulerParameters, 
                     ThreadScheduler scheduler) 

Create a new ThreadPool.

The variousSchedulerParameters and scheduler parameters hardly even qualify as hacks.

XXX This should take a ThreadPoolSpec as a parameter.

   public Thread threadStart(Runnable r) 

Create an explicit thread and return that thread handle. This is a new thread which is not subject to whatever concurrency limit the ThreadPool has. But, it will be scheduled by the ThreadPool's scheduler.

Parameter	Description
r	the Runnable to start the target thread on.

   public void destroy() 

Destroy this ThreadPool.

XXX this is a hack.

   void addWork(WorkItem wi) 

Add a task to the ThreadPool's task list.

XXX what happens if the same WorkItem is enqueued more than once?

   public Flow getFlow() 

   public boolean destroyed() 

   void enqueueWorkItem(WorkItem wi) 

   WorkItem dequeueWorkItem() 

   void signalWorkers() 

   void doWork() 

Do the work on this ThreadPool.

This function never returns.

All Packages  This Package  Class Hierarchy  Class Search  Index