Overview
-
module Async-
class Barrier- public
A general purpose synchronisation primitive, which allows one task to wait for a number of other tasks to complete. It can be used in conjunction with
class Async::Semaphore. -
class Clock- public
A convenient wrapper around the internal monotonic clock.
-
class Condition- public
A synchronization primitive, which allows fibers to wait until a particular condition is (edge) triggered.
-
class Idler -
class ListA general doublely linked list. This is used internally by
class Async::Barrierandclass Async::Conditionto manage child tasks.-
class NodeA linked list Node.
-
class Iterator
-
class ChildrenA list of children tasks.
-
class NodeA node in a tree, used for implementing the task hierarchy.
-
class Notification- public
A synchronization primitive, which allows fibers to wait until a notification is received. Does not block the task which signals the notification. Waiting tasks are resumed on next iteration of the reactor.
-
class Queue- public
A queue which allows items to be processed in order.
-
class LimitedQueue- public
-
class ReactorA wrapper around the the scheduler which binds it to the current thread automatically.
-
class SchedulerHandles scheduling of fibers. Implements the fiber scheduler interface.
-
class Semaphore- public
A synchronization primitive, which limits access to a given resource.
-
class StopRaised when a task is explicitly stopped.
-
class TimeoutError- public
Raised if a timeout occurs on a specific Fiber. Handled gracefully by
Task. -
class Task- public
-
class Variable -
class WaiterA composable synchronization primitive, which allows one task to wait for a number of other tasks to complete. It can be used in conjunction with
class Async::Semaphoreand/orclass Async::Barrier. -
class Wrapper- deprecated
Represents an asynchronous IO within a reactor.
-
class CancelledAn exception that occurs when the asynchronous operation was cancelled.
-
-
module KernelExtensions to all Ruby objects.