org.activeio.filter
Class AsyncWriteAsyncChannel.ObjectDispatcherX
java.lang.Object
org.activeio.filter.AsyncWriteAsyncChannel.ObjectDispatcherX
- All Implemented Interfaces:
- Runnable
- Enclosing class:
- AsyncWriteAsyncChannel
public static class AsyncWriteAsyncChannel.ObjectDispatcherX
- extends Object
- implements Runnable
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
AsyncWriteAsyncChannel.ObjectDispatcherX
public AsyncWriteAsyncChannel.ObjectDispatcherX(AsyncWriteAsyncChannel objectListener)
AsyncWriteAsyncChannel.ObjectDispatcherX
public AsyncWriteAsyncChannel.ObjectDispatcherX(AsyncWriteAsyncChannel objectListener,
int queueSize)
AsyncWriteAsyncChannel.ObjectDispatcherX
public AsyncWriteAsyncChannel.ObjectDispatcherX(AsyncWriteAsyncChannel objectListener,
Executor executor,
Channel queue)
add
public void add(Object o)
throws InterruptedException
- Throws:
InterruptedException
run
public void run()
- Specified by:
run
in interface Runnable
Copyright © -2009 The ActiveIO Project. All Rights Reserved.