From 36f3477d6e8762d8c5e04ac090515c69ee3b8098 Mon Sep 17 00:00:00 2001 From: heibaiying <31504331+heibaiying@users.noreply.github.com> Date: Mon, 15 Apr 2019 16:07:27 +0800 Subject: [PATCH] =?UTF-8?q?Update=20storm=E7=BC=96=E7=A8=8B=E6=A8=A1?= =?UTF-8?q?=E5=9E=8B.md?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- notes/storm编程模型.md | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/notes/storm编程模型.md b/notes/storm编程模型.md index 7b88c29..7c3805b 100644 --- a/notes/storm编程模型.md +++ b/notes/storm编程模型.md @@ -77,8 +77,9 @@ public interface ISpout extends Serializable { void deactivate(); /** - * 这是一个核心方法,主要通过在此方法中调用collector将tuples发送给下一个接收器,这个方法必须是非阻塞的。 * nextTuple/ack/fail/是在同一个线程中执行的,所以不用考虑线程安全方面。当没有tuples发出时应该 - * 让nextTuple休眠(sleep)一下,以免浪费CPU。 + * 这是一个核心方法,主要通过在此方法中调用collector将tuples发送给下一个接收器,这个方法必须是非阻塞的。 + * nextTuple/ack/fail/是在同一个线程中执行的,所以不用考虑线程安全方面。当没有tuples发出时应该让nextTuple + * 休眠(sleep)一下,以免浪费CPU。 */ void nextTuple();