Package | Description |
---|---|
org.apache.flink.streaming.runtime.tasks.mailbox |
Modifier and Type | Interface and Description |
---|---|
interface |
Mailbox
A mailbox is basically a blocking queue for inter-thread message exchange in form of
Runnable objects between
multiple producer threads and a single consumer. |
Modifier and Type | Class and Description |
---|---|
class |
MailboxImpl
Implementation of
Mailbox inspired by ArrayBlockingQueue and tailored towards
our use case with multiple writers, single reader and volatile reads instead of lock & read on MailboxImpl.count . |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.