Package org.agrona.concurrent

  • Interface Summary 
    InterfaceDescription
    Agent 
    AtomicBuffer
    Abstraction over a range of buffer types that allows type to be accessed with memory ordering semantics.
    EpochClock
    Retrieves the number of milliseconds since 1 Jan 1970 UTC.
    IdleStrategy
    Idle strategy for use by threads when they do not have work to do.
    MessageHandler
    Callback interface for processing of messages that are read from a buffer.
    NanoClock
    Functional interface for return the current time as system wide monotonic tick of 1 nanosecond precision.
    Pipe<E>
    A container for items processed in sequence
    QueuedPipe<E>
    Composed interface for concurrent queues and sequenced containers.
    RecordBuffer.RecordHandler
    Callback interface for reading elements out of the buffer.
    RecordBuffer.RecordWriter
    Interface for safely writing to the buffer.
  • Class Summary 
    ClassDescription
    AbstractConcurrentArrayQueue<E>
    Left over immutable queue fields.
    AgentRunner
    Base agent runner that is responsible for lifecycle of an Agent and ensuring exceptions are handled.
    BackoffIdleStrategy 
    BusySpinIdleStrategy
    Busy spin strategy targeted at lowest possible latency.
    CompositeAgent
    Compose several agents into one so a thread can be shared.
    ManyToManyConcurrentArrayQueue<E>
    Many producer to many consumer concurrent queue that is array backed.
    ManyToOneConcurrentArrayQueue<E>
    Many producer to one consumer concurrent queue that is array backed.
    ManyToOneConcurrentLinkedQueue<E>
    Concurrent linked Queue that can be used from many producers and a single consumer.
    MappedResizeableBuffer
    Supports regular, byte ordered, and atomic (memory ordered) access to an underlying buffer.
    NoOpIdleStrategy
    Low-latency idle strategy to be employed in loops that do significant work on each iteration such that any work in the idle strategy would be wasteful.
    OneToOneConcurrentArrayQueue<E>
    One producer to one consumer concurrent queue that is array backed.
    RecordBuffer
    A record buffer is an off-heap buffer with a series of records and a header that can be written to or read from multiple threads.
    SigInt
    Utility to allow the registration of a SIGINT handler that hides the unsupported Signal class.
    SigIntBarrier
    One time barrier for blocking a thread until a SIGINT signal is received from the operating system.
    SleepingIdleStrategy
    When idle this strategy is to sleep for a specified period.
    SystemEpochClock
    Implementation that calls System.currentTimeMillis().
    SystemNanoClock
    A NanoClock the delegates to System.nanoTime().
    UnsafeBuffer
    Supports regular, byte ordered, and atomic (memory ordered) access to an underlying buffer.
    YieldingIdleStrategy
    IdleStrategy that will call Thread.yield() when the work count is zero.

Copyright © 2014 - 2016 Real Logic Ltd. All Rights Reserved.



NOTHING
NOTHING
Add the Maven Dependecy to your project: maven dependecy for com.amazonaws : aws-java-sdk : 1.3.14