Signaller

Completion for recording and releasing a waiting thread. This class implements ManagedBlocker to avoid starvation when blocking actions pile up in ForkJoinPools.

final

class Signaller : Completion , ManagedBlocker {

Duration remaining;

MonoTime deadline;

bool interruptible;

bool interrupted;

Thread thread;

this(bool interruptible, Duration remaining, MonoTime deadline);

AbstractCompletableFuture tryFire(int ignore);

bool isReleasable();

bool block();

bool isLive();

}

Constructors

this this(bool interruptible, Duration remaining, MonoTime deadline): Undocumented in source.

Members

Functions

block bool block(): Undocumented in source. Be warned that the author may not have intended to support it.
isLive bool isLive(): Undocumented in source. Be warned that the author may not have intended to support it.
isReleasable bool isReleasable(): Undocumented in source. Be warned that the author may not have intended to support it.
tryFire AbstractCompletableFuture tryFire(int ignore): Undocumented in source. Be warned that the author may not have intended to support it.

Variables

deadline MonoTime deadline;: Undocumented in source.
interrupted bool interrupted;: Undocumented in source.
interruptible bool interruptible;: Undocumented in source.
remaining Duration remaining;: Undocumented in source.
thread Thread thread;: Undocumented in source.

Inherited Members

From Completion

next Completion next;: Undocumented in source.
tryFire AbstractCompletableFuture tryFire(int mode): Performs completion action if triggered, returning a dependent that may need propagation, if one exists.
isLive bool isLive(): Returns true if possibly still triggerable. Used by cleanStack.
run void run(): Undocumented in source. Be warned that the author may not have intended to support it.
exec bool exec(): Undocumented in source. Be warned that the author may not have intended to support it.

From ManagedBlocker

block bool block(): Possibly blocks the current thread, for example waiting for a lock or condition.
isReleasable bool isReleasable(): Returns {@code true} if blocking is unnecessary. @return {@code true} if blocking is unnecessary