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.JoinInputStream
Default size of read buffer.
defaultBufferSize - Static variable in class jsync.Pipe
Default size of buffer used to transfer data from the input stream to the output stream.

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.
jsync - package jsync
 

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.Concurrent
Start execution of activity threads.
start() - Method in class jsync.Conveyer
Start execution of reading and processing 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