Module org.snmp4j
Package org.snmp4j.util
Class MultiThreadedMessageDispatcher.MessageTask<A extends Address>
- java.lang.Object
-
- org.snmp4j.util.MultiThreadedMessageDispatcher.MessageTask<A>
-
- All Implemented Interfaces:
java.lang.Runnable
,WorkerTask
- Enclosing class:
- MultiThreadedMessageDispatcher
class MultiThreadedMessageDispatcher.MessageTask<A extends Address> extends java.lang.Object implements WorkerTask
-
-
Field Summary
Fields Modifier and Type Field Description private A
incomingAddress
private TransportMapping<? super A>
sourceTransport
private TransportStateReference
tmStateReference
private java.nio.ByteBuffer
wholeMessage
-
Constructor Summary
Constructors Constructor Description MessageTask(TransportMapping<? super A> sourceTransport, A incomingAddress, java.nio.ByteBuffer wholeMessage, TransportStateReference tmStateReference)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
interrupt()
Interrupts this task.void
join()
Waits until this task has been finished.void
run()
void
terminate()
TheWorkerPool
might call this method to hint the activeWorkTask
instance to complete execution as soon as possible.
-
-
-
Field Detail
-
sourceTransport
private final TransportMapping<? super A extends Address> sourceTransport
-
wholeMessage
private final java.nio.ByteBuffer wholeMessage
-
tmStateReference
private final TransportStateReference tmStateReference
-
-
Constructor Detail
-
MessageTask
public MessageTask(TransportMapping<? super A> sourceTransport, A incomingAddress, java.nio.ByteBuffer wholeMessage, TransportStateReference tmStateReference)
-
-
Method Detail
-
run
public void run()
- Specified by:
run
in interfacejava.lang.Runnable
-
terminate
public void terminate()
Description copied from interface:WorkerTask
TheWorkerPool
might call this method to hint the activeWorkTask
instance to complete execution as soon as possible.- Specified by:
terminate
in interfaceWorkerTask
-
join
public void join() throws java.lang.InterruptedException
Description copied from interface:WorkerTask
Waits until this task has been finished.- Specified by:
join
in interfaceWorkerTask
- Throws:
java.lang.InterruptedException
- if the join has been interrupted by another thread.
-
interrupt
public void interrupt()
Description copied from interface:WorkerTask
Interrupts this task.- Specified by:
interrupt
in interfaceWorkerTask
- See Also:
Thread.interrupt()
-
-