ch.dermitza.securenio.socket.secure

Class TaskWorker

java.lang.Object

ch.dermitza.securenio.socket.secure.TaskWorker

All Implemented Interfaces:

java.lang.Runnable

public class TaskWorker
extends java.lang.Object
implements java.lang.Runnable

A threaded implementation of a worker processing tasks required by an SSLEngine that is associated with a SecureSocket.

The worker sequentially processes tasks that need to be completed, in a FIFO fashion, notifying the associated TaskListener once they have been completed. The TaskWorker is otherwise waiting for incoming tasks via the addSocket(SecureSocket) method.

Since:

0.18

Constructor Summary

Constructors

Constructor and Description
TaskWorker(TaskListener listener) Create a TaskWorker instance with a single TaskListener reference.

Method Summary

Methods

Modifier and Type	Method and Description
void	addSocket(SecureSocket socket) Add a SecureSocket with an underlying SSLEngine that requires a task to be run.
boolean	isRunning() Check whether the TaskWorker is running.
void	run() The run() method of the TaskWorker.
void	setRunning(boolean running) Set the running status of the TaskWorker.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

TaskWorker

public TaskWorker(TaskListener listener)

Create a TaskWorker instance with a single TaskListener reference. The TaskListener is notified whenever any task has finished being processed by the TaskWorker.

Parameters:

listener - The TaskListener to be notified of completed tasks

Method Detail

addSocket

public void addSocket(SecureSocket socket)

Add a SecureSocket with an underlying SSLEngine that requires a task to be run. Tasks are run in a FIFO queue according to order of socket insertion.

Parameters:

socket - The SecureSocket that requires a task to be run

run

public void run()

The run() method of the TaskWorker. Here, sequential processing of SSLEngine tasks that need to be completed is done in a FIFO fashion, notifying the associated TaskListener once they have been completed. The TaskWorker is otherwise waiting for incoming tasks via the addSocket(SecureSocket) method.

Specified by:

run in interface java.lang.Runnable

isRunning

public boolean isRunning()

Check whether the TaskWorker is running.

Returns:

true if it is running, false otherwise

setRunning

public void setRunning(boolean running)

Set the running status of the TaskWorker. If the running status of the worker is set to false, the TaskWorker is interrupted (if waiting for a task) in order to cleanly shutdown.

Parameters:

running - Whether the TaskWorker should run or not