Package | Description |
---|---|
org.jetlang.channels | |
org.jetlang.core | |
org.jetlang.fibers |
Modifier and Type | Method and Description |
---|---|
Disposable |
MemoryRequestChannel.publish(DisposingExecutor target,
R request,
Callback<V> reply) |
Disposable |
RequestChannel.publish(DisposingExecutor fiber,
R request,
Callback<V> reply) |
Disposable |
AsyncRequest.publish(RequestChannel<R,V> channel,
R req,
Callback<List<V>> onResponse) |
Disposable |
MemoryRequestChannel.subscribe(DisposingExecutor fiber,
Callback<Request<R,V>> onRequest) |
Disposable |
RequestChannel.subscribe(DisposingExecutor fiber,
Callback<Request<R,V>> onRequest) |
Disposable |
MemoryRequestChannel.subscribe(DisposingExecutor fiber,
Callback<Request<R,V>> onRequest,
Callback<SessionClosed<R>> onRequestEnd) |
Disposable |
RequestChannel.subscribe(DisposingExecutor fiber,
Callback<Request<R,V>> onRequest,
Callback<SessionClosed<R>> onRequestEnd) |
Disposable |
MemoryChannel.subscribe(DisposingExecutor queue,
Callback<T> onReceive) |
Disposable |
Subscriber.subscribe(DisposingExecutor executor,
Callback<T> receive)
Subscribe to receive messages produced by this subscriber
|
Disposable |
CompositeChannel.subscribe(DisposingExecutor executor,
Callback<T> receive) |
Disposable |
MemoryChannel.subscribe(Subscribable<T> sub) |
Disposable |
Subscriber.subscribe(Subscribable<T> sub) |
Disposable |
CompositeChannel.subscribe(Subscribable<T> sub) |
Disposable |
MemoryChannel.subscribeOnProducerThread(DisposingExecutor queue,
Callback<T> callbackOnQueue) |
static <R,V> Disposable |
AsyncRequest.withOneReply(Fiber fiber,
RequestChannel<R,V> channel,
R req,
Callback<V> onReply) |
static <R,V> Disposable |
AsyncRequest.withOneReply(Fiber fiber,
RequestChannel<R,V> channel,
R req,
Callback<V> onReply,
long timeout,
TimeUnit unit,
Runnable onTimeout) |
Modifier and Type | Interface and Description |
---|---|
interface |
RunnableExecutor
Queues and executes events.
|
interface |
Scheduler
Component that can schedule events to execute in the future.
|
Modifier and Type | Class and Description |
---|---|
class |
RunnableExecutorImpl
Default implementation that queues and executes events.
|
class |
SchedulerImpl
Default implementation for scheduling events for execution on fibers.
|
class |
SynchronousDisposingExecutor
A synchronous execute typically used for testing.
|
Modifier and Type | Method and Description |
---|---|
Disposable |
Scheduler.schedule(Runnable command,
long delay,
TimeUnit unit)
Creates and executes a one-shot action that becomes enabled after the given delay.
|
Disposable |
SchedulerImpl.schedule(Runnable _command,
long delay,
TimeUnit unit) |
Disposable |
Scheduler.scheduleAtFixedRate(Runnable command,
long initialDelay,
long period,
TimeUnit unit)
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.
|
Disposable |
SchedulerImpl.scheduleAtFixedRate(Runnable _command,
long initialDelay,
long interval,
TimeUnit unit) |
Disposable |
Scheduler.scheduleWithFixedDelay(Runnable command,
long initialDelay,
long delay,
TimeUnit unit)
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.
|
Disposable |
SchedulerImpl.scheduleWithFixedDelay(Runnable command,
long initialDelay,
long interval,
TimeUnit unit) |
Modifier and Type | Method and Description |
---|---|
void |
RunnableExecutorImpl.add(Disposable r) |
void |
SynchronousDisposingExecutor.add(Disposable runOnStop) |
void |
DisposingExecutor.add(Disposable disposable)
Add a
Disposable to be disposed when this component is disposed |
boolean |
RunnableExecutorImpl.remove(Disposable disposable) |
boolean |
SynchronousDisposingExecutor.remove(Disposable disposable) |
boolean |
DisposingExecutor.remove(Disposable disposable)
Remove a
Disposable from being disposed when this component is disposed |
Modifier and Type | Interface and Description |
---|---|
interface |
Fiber
Fibers provide event queueing, scheduling, and full pub/sub capabilities when combined with a
Channel . |
interface |
NioFiber |
Modifier and Type | Class and Description |
---|---|
class |
FiberStub
Provides a deterministic fiber implementation for testing.
|
class |
NioFiberImpl |
class |
PoolFiberFactory
Factory that creates
Fiber instances that share threads. |
class |
ThreadFiber
Fiber implementation backed by a dedicated thread for execution.
|
Modifier and Type | Field and Description |
---|---|
List<Disposable> |
FiberStub.Disposables |
Modifier and Type | Method and Description |
---|---|
Disposable |
FiberStub.schedule(Runnable runnable,
long l,
TimeUnit timeUnit) |
Disposable |
ThreadFiber.schedule(Runnable command,
long delay,
TimeUnit unit)
Schedule a Runnable to execute in the future.
|
Disposable |
NioFiberImpl.schedule(Runnable command,
long delay,
TimeUnit unit) |
Disposable |
FiberStub.scheduleAtFixedRate(Runnable runnable,
long first,
long interval,
TimeUnit timeUnit) |
Disposable |
ThreadFiber.scheduleAtFixedRate(Runnable command,
long initialDelay,
long delay,
TimeUnit unit)
Schedule recurring event.
|
Disposable |
NioFiberImpl.scheduleAtFixedRate(Runnable command,
long initialDelay,
long period,
TimeUnit unit) |
Disposable |
FiberStub.scheduleWithFixedDelay(Runnable command,
long initialDelay,
long delay,
TimeUnit unit) |
Disposable |
ThreadFiber.scheduleWithFixedDelay(Runnable command,
long initialDelay,
long delay,
TimeUnit unit) |
Disposable |
NioFiberImpl.scheduleWithFixedDelay(Runnable command,
long initialDelay,
long delay,
TimeUnit unit) |
Modifier and Type | Method and Description |
---|---|
void |
FiberStub.add(Disposable disposable) |
void |
ThreadFiber.add(Disposable runOnStop) |
void |
NioFiberImpl.add(Disposable disposable) |
boolean |
FiberStub.remove(Disposable disposable) |
boolean |
ThreadFiber.remove(Disposable disposable) |
boolean |
NioFiberImpl.remove(Disposable disposable) |
Copyright © 2017. All Rights Reserved.