From 3e5c77aaba2b03841c22db99b3075ae78a96c0e1 Mon Sep 17 00:00:00 2001
From: Jim <thinker8581@qq.com>
Date: Wed, 26 Apr 2017 13:43:13 +0800
Subject: [PATCH] =?UTF-8?q?=E6=8F=90=E5=8D=87=E6=95=88=E7=8E=87?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

队列中未完成的任务，消费完成后立即进行后继的队列检查， 跳过 SLEEP，以提升效率。
---
 src/luwak.c | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/src/luwak.c b/src/luwak.c
index 83f4664..177bae9 100644
--- a/src/luwak.c
+++ b/src/luwak.c
@@ -38,6 +38,7 @@ void *_t_redis(void *t_redis)
   while(1) {
     if (lwk_redis_llen(server, port, key) > 0) {
       system(command);
+      continue;
     }
     usleep(U_SLEEP_TIME);
   }
@@ -89,6 +90,7 @@ void *_t_rabbit(void *t_rabbit)
     if (lwk_rabbit_llen(server, port, username, password, vhost, queue, passive, durable, exclusive, auto_delete) > 0) {
       //LOG_PRINT(LOG_DEBUG, "!!!!!!!!!!RABBIT:%s---->%d\n", queue, lwk_rabbit_llen(server, port, queue, passive, durable, exclusive, auto_delete));
       system(command);
+      continue;
     }
     usleep(U_SLEEP_TIME);
   }