JobNotification

Ditto

abstract

class JobNotification {

T[] copy(T[] dest, T2[] src) via import ocean.core.array.Mutation : copy;;

struct Job via import ocean.util.aio.internal.JobQueue : Job;;

void wake_();

void wait_();

void wait(Job* job, typeof(this.remove_dg) remove_dg);

void register(Job* job, typeof(this.remove_dg) remove_dg);

void unregister();

void discardResults();

}

Members

Functions

discardResults void discardResults(): Should be called by the concrete classes to inform the AIO that results of this operation are no longer needed.
register void register(Job* job, typeof(this.remove_dg) remove_dg): Registers the Job instance with this job notification and sets up removal delegate.
unregister void unregister(): Detaches the Job instance from this JobNotification (the opposite of register).
wait void wait(Job* job, typeof(this.remove_dg) remove_dg): Cedes the control from the suspendable job, waiting for the aio operation to be done. Called by AsyncIO framework internally.
wait_ void wait_(): Cedes the control from the suspendable job, waiting for the aio operation to be done. Implementation is defined by the concrete classes.
wake void wake(): Yields the control to the suspended job, indicating that the aio operation has been done. Called by the AsyncIO framework internally.
wake_ void wake_(): Yields the control to the suspendable job, indicating that the aio operation has been done.

Meta

Source

See Implementation

ocean util aio JobNotification classes

JobNotification