org.jboss.jms.server.remoting
Class DirectThreadPool

java.lang.Object
  extended by org.jboss.jms.server.remoting.DirectThreadPool
All Implemented Interfaces:
org.jboss.util.threadpool.ThreadPool

public class DirectThreadPool
extends java.lang.Object
implements org.jboss.util.threadpool.ThreadPool

A "noop" thread pool that just forwards the invocations, without doing any kind of pooling. We use it for the "socket" remoting callback server.

Version:
$Revision: 2977 $ $Id: DirectThreadPool.java 2977 2007-08-08 15:32:14Z timfox $
Author:
Ovidiu Feodorov

Constructor Summary
DirectThreadPool()
           
 
Method Summary
 void run(java.lang.Runnable runnable)
           
 void run(java.lang.Runnable runnable, long startTimeout, long completeTimeout)
           
 void runTask(org.jboss.util.threadpool.Task task)
           
 void runTaskWrapper(org.jboss.util.threadpool.TaskWrapper wrapper)
           
 void stop(boolean immediate)
           
 void waitForTasks()
           
 void waitForTasks(long maxWaitTime)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

DirectThreadPool

public DirectThreadPool()
Method Detail

stop

public void stop(boolean immediate)
Specified by:
stop in interface org.jboss.util.threadpool.ThreadPool

waitForTasks

public void waitForTasks()
                  throws java.lang.InterruptedException
Specified by:
waitForTasks in interface org.jboss.util.threadpool.ThreadPool
Throws:
java.lang.InterruptedException

waitForTasks

public void waitForTasks(long maxWaitTime)
                  throws java.lang.InterruptedException
Specified by:
waitForTasks in interface org.jboss.util.threadpool.ThreadPool
Throws:
java.lang.InterruptedException

runTaskWrapper

public void runTaskWrapper(org.jboss.util.threadpool.TaskWrapper wrapper)
Specified by:
runTaskWrapper in interface org.jboss.util.threadpool.ThreadPool

runTask

public void runTask(org.jboss.util.threadpool.Task task)
Specified by:
runTask in interface org.jboss.util.threadpool.ThreadPool

run

public void run(java.lang.Runnable runnable)
Specified by:
run in interface org.jboss.util.threadpool.ThreadPool

run

public void run(java.lang.Runnable runnable,
                long startTimeout,
                long completeTimeout)
Specified by:
run in interface org.jboss.util.threadpool.ThreadPool


Copyright © 2006 JBoss Inc. All Rights Reserved.