Package | Description |
---|---|
com.caucho.bam.mailbox | |
com.caucho.cloud.bam | |
com.caucho.env.actor | |
com.caucho.message.journal |
Modifier and Type | Method and Description |
---|---|
protected ActorProcessor<Packet> |
MultiworkerMailbox.createProcessor() |
Constructor and Description |
---|
MailboxQueue2(int capacity,
ActorProcessor<Packet> processor) |
Modifier and Type | Class and Description |
---|---|
class |
HmuxWorker
Queue of hmtp packets
|
Modifier and Type | Method and Description |
---|---|
protected ActorProcessor<Packet> |
HmuxQueue.createProcessor() |
Modifier and Type | Class and Description |
---|---|
class |
AbstractActorProcessor<T>
Processes an actor item.
|
class |
AbstractWorkerQueue<T>
Ring-based memory queue processed by a single worker.
|
Modifier and Type | Method and Description |
---|---|
ActorQueueApi<T> |
ActorQueueBuilder.build(ActorProcessor<? super T>... processors) |
Constructor and Description |
---|
ActorQueue(int capacity,
RingItemFactory<T> itemFactory,
ActorProcessor<? super T>... processors) |
MultiworkerActorQueue(int capacity,
int multiworkerOffset,
ActorProcessor<? super T>... processors) |
ValueActorQueue(int capacity,
ActorProcessor<? super T>... processors) |
Modifier and Type | Class and Description |
---|---|
class |
JournalWriteActor
Actor-processor for writing to the transaction log.
|