Module swim.concurrent

Package swim.concurrent

Class Sync<T>

java.lang.Object

swim.concurrent.Sync<T>

All Implemented Interfaces:

ForkJoinPool.ManagedBlocker, Cont<T>

public class Sync<T>
extends Object
implements Cont<T>, ForkJoinPool.ManagedBlocker

A Continuation whose completion can be synchronously awaited. A Sync continuation is used to await the completion of an asynchronous operation.

Constructor Summary

Constructors

Constructor	Description
Sync()	Constructs a new Sync continuation that awaits a value of type T.

Method Summary

Modifier and Type	Method	Description
T	await()	Waits an unbounded amount of time for this Sync continuation to complete.
T	await(long timeout)	Waits a maximum of timeout milliseconds for this Sync continuation to complete.
void	bind(T value)	Invoked when the asynchronous operation completes with a value.
boolean	block()
boolean	isReleasable()
void	trap(Throwable error)	Invoked when the asynchronous operation fails with an error.

Methods inherited from class java.lang.Object

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

Constructor Detail

Sync

public Sync()

Constructs a new Sync continuation that awaits a value of type T.

Method Detail

isReleasable

public boolean isReleasable()

Specified by:

isReleasable in interface ForkJoinPool.ManagedBlocker

block

public boolean block()
              throws InterruptedException

Specified by:

block in interface ForkJoinPool.ManagedBlocker

Throws:

InterruptedException

bind

public void bind(T value)

Description copied from interface: Cont

Invoked when the asynchronous operation completes with a value.

Specified by:

bind in interface Cont<T>

trap

public void trap(Throwable error)

Description copied from interface: Cont

Invoked when the asynchronous operation fails with an error.

Specified by:

trap in interface Cont<T>

await

public T await(long timeout)
        throws InterruptedException

Waits a maximum of timeout milliseconds for this Sync continuation to complete. Performs a managed block to avoid thread starvation while waiting.

Throws:

SyncException - if the timeout milliseconds elapses and this Sync continuation still hasn't been completed.

InterruptedException

await

public T await()
        throws InterruptedException

Waits an unbounded amount of time for this Sync continuation to complete. Performs a managed block to avoid thread starvation while waiting.

Throws:

InterruptedException