@@ -130,14 +130,14 @@ public class ConcurrentTask<T> {
nullTimes++;
if (10 <= nullTimes) {
if (immortal) {
- Util.sleep(10);
+ Util.sleep(2);
continue;
} else {
LOG.info("no element.worker exist.");
break;
}
- Util.sleep(5);