StefanRRichter commented on a change in pull request #8431: [FLINK-12480]
Introduce mailbox to StreamTask main-loop
URL: https://github.com/apache/flink/pull/8431#discussion_r283709628
##########
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java
##########
@@ -124,6 +127,12 @@
/** The logger used by the StreamTask and its subclasses. */
private static final Logger LOG =
LoggerFactory.getLogger(StreamTask.class);
+ /** Special value, letter that terminates the mailbox loop. */
+ private static final Runnable POISON_LETTER = () -> {};
+
+ /** Special value, letter that "wakes up" a waiting mailbox loop. */
+ private static final Runnable DEFAULT_ACTION_AVAILABLE = () -> {};
Review comment:
Yes, once we have non-blocking inputs.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
With regards,
Apache Git Services
