Contents | Package | Class | Tree | Deprecated | Index | Help
PREV | NEXT SHOW LISTS | HIDE LISTS
A B C D E G I J L M N P Q R S T U W

A

Activity interface jsync.Activity.
Interface for activities executed concurrently by class Concurrent.
Assert class jsync.Assert.
Class for checking program invariants.
Assert(). Constructor for class jsync.Assert
AssertionFailed error jsync.AssertionFailed.
Exception raised by Assert class when assertion is failed.

B

Barrier class jsync.Barrier.
Class for synchronizing concurrent execution of several threads.
Barrier(). Constructor for class jsync.Barrier
Default constructor of Barrier object.
Barrier(int). Constructor for class jsync.Barrier
Constructor of Barrier object, which also set number of threads to be meet at barrier.
between(InputStream, OutputStream, int). Static method in class jsync.Pipe
Establish connection between input and output streams with specified size of buffer used for data transfer.
between(InputStream, OutputStream). Static method in class jsync.Pipe
Establish connection between input and output streams with default buffer size.

C

Concurrent class jsync.Concurrent.
Class initiating parallel execution of several threads and collecting their results.
Concurrent(Activity[]). Constructor for class jsync.Concurrent
Constructor of Concurrent class.
Conveyer class jsync.Conveyer.
Class for parallel input data reading and processing.
Conveyer(InputStream, int, int). Constructor for class jsync.Conveyer
Create Conveyer object with specified size of cyclic buffer and block size.
Conveyer(InputStream, int). Constructor for class jsync.Conveyer
Create Conveyer object with specified block size.
close(). Method in class jsync.JoinInputStream
Close all attached input streams and stop their listener threads.

D

defaultBufferSize. Static variable in class jsync.Pipe
Default size of buffer used to transfer data from the input stream to the output stream.
defaultBufferSize. Static variable in class jsync.JoinInputStream
Default size of read buffer.

E

Event class jsync.Event.
Event is synchronization object which can be either in signaled or non-signaled state.
Event(). Constructor for class jsync.Event
Create event with non-signaled initial state.
Event(boolean). Constructor for class jsync.Event
Create event with specified initial state.
enter(). Method in class jsync.Mutex
Lock mutex.
enter(long). Method in class jsync.Mutex
Try to lock mutex within specified period of time.

G

get(). Method in class jsync.Queue
Wait until queue is not empty and take object from the queue.
get(long). Method in class jsync.Queue
Wait at most timeout miliseconds until queue becomes not empty and take object from the queue.
getStreamIndex(). Method in class jsync.JoinInputStream
Get index of thread from which data was retrieved in last read operation.

I

InterruptedError error jsync.InterruptedError.
Exception raised when thread is blocked in wait() or join() method was interrupted by another thread.
isEmpty(). Method in class jsync.Queue
Check if queue is empty.

J

JoinInputStream class jsync.JoinInputStream.
Class multiplexing input from several streams.
JoinInputStream(InputStream[], int). Constructor for class jsync.JoinInputStream
Create stream joining streams specified in the array.
JoinInputStream(InputStream, InputStream, int). Constructor for class jsync.JoinInputStream
Create stream joining two specified streams.
JoinInputStream(InputStream, InputStream). Constructor for class jsync.JoinInputStream
Create stream joining two specified streams.

L

Lock class jsync.Lock.
Class for supporting resource locking.
Lock(). Constructor for class jsync.Lock
leave(). Method in class jsync.Mutex
Release mutex.

M

Mutex class jsync.Mutex.
Class for providing mutual exclusion of threads.
Mutex(). Constructor for class jsync.Mutex

N

NotOwnerError error jsync.NotOwnerError.
This error is thrown when thread releasing lock is not one who set this lock.
NotOwnerError(). Constructor for class jsync.NotOwnerError

P

Pipe class jsync.Pipe.
This class links input and output streams so that data taken from input stream is transfered to the output stream.
Pipe(). Constructor for class jsync.Pipe
process(byte[], int, int). Method in class jsync.Conveyer
Abstract method to be implemented in derived class.
put(Object). Method in class jsync.Queue
Put object in queue.

Q

Queue class jsync.Queue.
First-In First-Out queue for synchronizing data exchange between several threads.
Queue(). Constructor for class jsync.Queue

R

reach(). Method in class jsync.Barrier
This method is called by thread reached barrier.
read(). Method in class jsync.JoinInputStream
Reads the next byte of data from one of input streams.
read(byte[], int, int). Method in class jsync.JoinInputStream
Reads up to len bytes of data from one of input streams into an array of bytes.
reset(int). Method in class jsync.Barrier
Reset Barrier object.
reset(). Method in class jsync.Event
Reset event to non-signaled state.
run(). Method in interface jsync.Activity
Method invoked by Concurrent class.

S

Semaphore class jsync.Semaphore.
Classical Dijkstra semaphore with wait() and signal() operations.
Semaphore(). Constructor for class jsync.Semaphore
Create semaphore with zero counter value.
Semaphore(int). Constructor for class jsync.Semaphore
Create semaphore with specified non-negative counter value.
setExclusive(long). Method in class jsync.Lock
Lock resource in exclusive mode.
setExclusive(). Method in class jsync.Lock
Lock resource in exclusive mode without limitation of waiting time.
setInputStream(InputStream). Method in class jsync.Conveyer
Set new input stream for conveyer.
setShared(long). Method in class jsync.Lock
Lock resource in shared mode.
setShared(). Method in class jsync.Lock
Lock resource in shared mode without limitation of waiting time.
signal(). Method in class jsync.Event
Set event to signaled state.
signal(). Method in class jsync.Semaphore
Increment value of the counter.
start(). Method in class jsync.Conveyer
Start execution of reading and processing threads.
start(). Method in class jsync.Concurrent
Start execution of activity threads.

T

that(boolean). Static method in class jsync.Assert
Check specified condition and raise AssertionFailed exception if it is not true.
that(String, boolean). Static method in class jsync.Assert
Check specified condition and raise AssertionFailed exception if it is not true.

U

unsetExclusive(). Method in class jsync.Lock
Release exclusive lock.
unsetShared(). Method in class jsync.Lock
Release shared lock.

W

waitAll(). Method in class jsync.Concurrent
Wait until all started threads finish their execution.
waitAll(long). Method in class jsync.Concurrent
Wait at most timeout miliseconds until all started threads finish their execution.
waitEvent(). Method in class jsync.Event
Wait until event is set to signaled state.
waitEvent(long). Method in class jsync.Event
Wait during specified amount of time until event is set to signaled state.
waitOne(). Method in class jsync.Concurrent
Wait until one of the started threads finish it's execution.
waitOne(long). Method in class jsync.Concurrent
Wait during specified period of time until one of started threads finish it's execution.
waitSemaphore(). Method in class jsync.Semaphore
Wait for non-zero value of counter.
waitSemaphore(long). Method in class jsync.Semaphore
Wait at most timeout miliseconds for non-zero value of counter.
waitTermination(). Method in class jsync.Conveyer
Wait termination of data processing thread.

A B C D E G I J L M N P Q R S T U W
Contents | Package | Class | Tree | Deprecated | Index | Help
PREV | NEXT SHOW LISTS | HIDE LISTS