- schedule(Runnable, long, TimeUnit) - Method in interface org.jetlang.core.Scheduler
-
Creates and executes a one-shot action that becomes enabled after the given delay.
- schedule(Runnable, long, TimeUnit) - Method in class org.jetlang.core.SchedulerImpl
-
- schedule(Runnable, long, TimeUnit) - Method in class org.jetlang.fibers.FiberStub
-
- schedule(Runnable, long, TimeUnit) - Method in class org.jetlang.fibers.NioFiberImpl
-
- schedule(Runnable, long, TimeUnit) - Method in class org.jetlang.fibers.ThreadFiber
-
Schedule a Runnable to execute in the future.
- scheduleAtFixedRate(Runnable, long, long, TimeUnit) - Method in interface org.jetlang.core.Scheduler
-
Creates and executes a periodic action that becomes enabled first after the given initial delay,
and subsequently with the given period; that is executions will commence after initialDelay
then initialDelay+period, then initialDelay + 2 * period, and so on.
- scheduleAtFixedRate(Runnable, long, long, TimeUnit) - Method in class org.jetlang.core.SchedulerImpl
-
- scheduleAtFixedRate(Runnable, long, long, TimeUnit) - Method in class org.jetlang.fibers.FiberStub
-
- scheduleAtFixedRate(Runnable, long, long, TimeUnit) - Method in class org.jetlang.fibers.NioFiberImpl
-
- scheduleAtFixedRate(Runnable, long, long, TimeUnit) - Method in class org.jetlang.fibers.ThreadFiber
-
Schedule recurring event.
- Scheduled - Variable in class org.jetlang.fibers.FiberStub
-
- ScheduledEvent(Runnable, long, TimeUnit) - Constructor for class org.jetlang.fibers.FiberStub.ScheduledEvent
-
- ScheduledEvent(Runnable, long, long, TimeUnit, boolean) - Constructor for class org.jetlang.fibers.FiberStub.ScheduledEvent
-
- ScheduledEvent(Runnable, long, long, TimeUnit) - Constructor for class org.jetlang.fibers.FiberStub.ScheduledEvent
-
- Scheduler - Interface in org.jetlang.core
-
Component that can schedule events to execute in the future.
- SchedulerImpl - Class in org.jetlang.core
-
Default implementation for scheduling events for execution on fibers.
- SchedulerImpl(Executor, ScheduledExecutorService) - Constructor for class org.jetlang.core.SchedulerImpl
-
- SchedulerImpl(Executor) - Constructor for class org.jetlang.core.SchedulerImpl
-
- SchedulerImpl(DisposingExecutor, ScheduledExecutorService) - Constructor for class org.jetlang.core.SchedulerImpl
-
- scheduleWithFixedDelay(Runnable, long, long, TimeUnit) - Method in interface org.jetlang.core.Scheduler
-
Creates and executes a periodic action that becomes enabled first
after the given initial delay, and subsequently with the
given delay between the termination of one execution and the
commencement of the next.
- scheduleWithFixedDelay(Runnable, long, long, TimeUnit) - Method in class org.jetlang.core.SchedulerImpl
-
- scheduleWithFixedDelay(Runnable, long, long, TimeUnit) - Method in class org.jetlang.fibers.FiberStub
-
- scheduleWithFixedDelay(Runnable, long, long, TimeUnit) - Method in class org.jetlang.fibers.NioFiberImpl
-
- scheduleWithFixedDelay(Runnable, long, long, TimeUnit) - Method in class org.jetlang.fibers.ThreadFiber
-
- Session - Interface in org.jetlang.channels
-
Uniquely identifies a request/reply session.
- SessionClosed<R> - Interface in org.jetlang.channels
-
Message sent when a request session is closed.
- setResponseCount(int) - Method in class org.jetlang.channels.AsyncRequest
-
- setRunning(boolean) - Method in class org.jetlang.core.CappedBlockingQueue
-
- setRunning(boolean) - Method in interface org.jetlang.core.EventQueue
-
- setRunning(boolean) - Method in class org.jetlang.core.NioQueueSwapper
-
- setRunning(boolean) - Method in class org.jetlang.core.QueueSwapper
-
- setRunning(boolean) - Method in class org.jetlang.core.RunnableBlockingQueue
-
- setRunning(boolean) - Method in class org.jetlang.core.SynchronousExecutor
-
- setTimeout(Callback<List<V>>, long, TimeUnit) - Method in class org.jetlang.channels.AsyncRequest
-
- size() - Method in class org.jetlang.channels.SubscriberList
-
- size() - Method in interface org.jetlang.core.DisposingExecutor
-
Return the number of
Disposable
instances registered with this instance.
- size() - Method in class org.jetlang.core.MessageBuffer
-
- size() - Method in interface org.jetlang.core.MessageReader
-
- size() - Method in class org.jetlang.core.NioQueueSwapper
-
- size() - Method in class org.jetlang.core.QueueSwapper
-
- size() - Method in class org.jetlang.core.RunnableExecutorImpl
-
- size() - Method in class org.jetlang.core.SynchronousDisposingExecutor
-
- size() - Method in class org.jetlang.fibers.FiberStub
-
- size() - Method in class org.jetlang.fibers.NioFiberImpl
-
- size() - Method in class org.jetlang.fibers.ThreadFiber
-
- start() - Method in interface org.jetlang.fibers.Fiber
-
Start consuming events
- start() - Method in class org.jetlang.fibers.FiberStub
-
- start() - Method in class org.jetlang.fibers.NioFiberImpl
-
- start() - Method in class org.jetlang.fibers.ThreadFiber
-
Start thread
- Subscribable<T> - Interface in org.jetlang.channels
-
Interface to subscribe to events on producing thread(s).
- subscribe(DisposingExecutor, Callback<T>) - Method in class org.jetlang.channels.CompositeChannel
-
- subscribe(Subscribable<T>) - Method in class org.jetlang.channels.CompositeChannel
-
- subscribe(DisposingExecutor, Callback<T>) - Method in class org.jetlang.channels.MemoryChannel
-
- subscribe(Subscribable<T>) - Method in class org.jetlang.channels.MemoryChannel
-
- subscribe(DisposingExecutor, Callback<Request<R, V>>) - Method in class org.jetlang.channels.MemoryRequestChannel
-
- subscribe(DisposingExecutor, Callback<Request<R, V>>, Callback<SessionClosed<R>>) - Method in class org.jetlang.channels.MemoryRequestChannel
-
- subscribe(DisposingExecutor, Callback<Request<R, V>>) - Method in interface org.jetlang.channels.RequestChannel
-
- subscribe(DisposingExecutor, Callback<Request<R, V>>, Callback<SessionClosed<R>>) - Method in interface org.jetlang.channels.RequestChannel
-
- subscribe(DisposingExecutor, Callback<T>) - Method in interface org.jetlang.channels.Subscriber
-
Subscribe to receive messages produced by this subscriber
- subscribe(Subscribable<T>) - Method in interface org.jetlang.channels.Subscriber
-
- subscribeOnProducerThread(DisposingExecutor, Callback<T>) - Method in class org.jetlang.channels.MemoryChannel
-
- Subscriber<T> - Interface in org.jetlang.channels
-
Interface for components that allow for message subscriptions
- subscriberCount() - Method in class org.jetlang.channels.MemoryChannel
-
- SubscriberList<T> - Class in org.jetlang.channels
-
User: mrettig
Date: Aug 29, 2009
- SubscriberList() - Constructor for class org.jetlang.channels.SubscriberList
-
- swap(EventBuffer) - Method in class org.jetlang.core.CappedBlockingQueue
-
- swap(EventBuffer) - Method in interface org.jetlang.core.EventQueue
-
- swap(EventBuffer) - Method in class org.jetlang.core.NioQueueSwapper
-
- swap(EventBuffer) - Method in class org.jetlang.core.QueueSwapper
-
- swap(EventBuffer) - Method in class org.jetlang.core.RunnableBlockingQueue
-
- SynchronousDisposingExecutor - Class in org.jetlang.core
-
A synchronous execute typically used for testing.
- SynchronousDisposingExecutor() - Constructor for class org.jetlang.core.SynchronousDisposingExecutor
-
- SynchronousExecutor - Class in org.jetlang.core
-
Executor that runs tasks on the current thread.
- SynchronousExecutor() - Constructor for class org.jetlang.core.SynchronousExecutor
-