Package org.apache.pivot.io

Class IOTask<V>

java.lang.Object

org.apache.pivot.util.concurrent.Task<V>

org.apache.pivot.io.IOTask<V>

Direct Known Subclasses:

Image.LoadTask, Query

public abstract class IOTask<V>
extends Task<V>

Abstract base class for asynchronous input/output tasks.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected class	IOTask.MonitoredInputStream	Input stream that monitors the bytes that are read from it by incrementing the bytesReceived member variable.
protected class	IOTask.MonitoredOutputStream	Output stream that monitors the bytes that are written to it by incrementing the bytesSent member variable.

Field Summary

Fields

Modifier and Type	Field	Description
protected java.util.concurrent.atomic.AtomicLong	bytesReceived
protected java.util.concurrent.atomic.AtomicLong	bytesSent

Fields inherited from class org.apache.pivot.util.concurrent.Task

abort, DEFAULT_EXECUTOR_SERVICE, timeout

Constructor Summary

Constructors

Constructor	Description
IOTask()
IOTask(java.util.concurrent.ExecutorService executorService)

Method Summary

Methods inherited from class org.apache.pivot.util.concurrent.Task

abort, execute, execute, execute, getBackgroundThread, getExecutorService, getFault, getResult, getTimeout, isPending, setTimeout

Methods inherited from class java.lang.Object

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

Field Detail

bytesSent

protected java.util.concurrent.atomic.AtomicLong bytesSent

bytesReceived

protected java.util.concurrent.atomic.AtomicLong bytesReceived

Constructor Detail

IOTask

public IOTask()

IOTask

public IOTask(java.util.concurrent.ExecutorService executorService)