public class SynchronousReactor extends Object implements Reactor
SynchronousReactor
object is used to execute the
ready operations of within a single synchronous thread. This is
used when the I/O operations to be performed do not require much
time to execute and so will not block the execution thread.Constructor and Description |
---|
SynchronousReactor()
Constructor for the
SynchronousReactor object. |
SynchronousReactor(boolean cancel)
Constructor for the
SynchronousReactor object. |
Modifier and Type | Method and Description |
---|---|
void |
process(Operation task)
This method is used to execute the provided operation without
the need to specifically check for I/O events.
|
void |
process(Operation task,
int require)
This method is used to execute the provided operation when there
is an I/O event that task is interested in.
|
void |
stop()
This is used to stop the reactor so that further requests to
execute operations does nothing.
|
public SynchronousReactor() throws IOException
SynchronousReactor
object. This
is used to create a reactor that does not require thread pooling
to execute the ready operations. All I/O operations are run
in the selection thread and should complete quickly.IOException
public SynchronousReactor(boolean cancel) throws IOException
SynchronousReactor
object. This
is used to create a reactor that does not require thread pooling
to execute the ready operations. All I/O operations are run
in the selection thread and should complete quickly.cancel
- determines the selection key should be cancelledIOException
public void process(Operation task) throws IOException
SelectableChannel
is
ready, or if the I/O operation can be performed without knowing
if the channel is ready. Typically this is an efficient means
to perform a poll rather than a select on the channel.process
in interface Reactor
task
- this is the task to execute immediatelyIOException
public void process(Operation task, int require) throws IOException
SelectableChannel
object to determine
the events that are ready on the channel. If this reactor is
interested in any of the ready events then the task is executed.process
in interface Reactor
task
- this is the task to execute on interested eventsrequire
- this is the bit-mask value for interested eventsIOException
public void stop() throws IOException
stop
in interface Reactor
IOException
Copyright © 2022. All rights reserved.