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.