Commit 95ec0538 authored by yanzg's avatar yanzg

消除成功接收处理

parent 8309c227
...@@ -4,6 +4,8 @@ import com.yanzuoguang.util.helper.EventRun; ...@@ -4,6 +4,8 @@ import com.yanzuoguang.util.helper.EventRun;
/** /**
* Runnable时间触发处理器 * Runnable时间触发处理器
*
* @author 颜佐光
*/ */
public class RunExecute implements EventRun<Runnable> { public class RunExecute implements EventRun<Runnable> {
/** /**
...@@ -12,6 +14,7 @@ public class RunExecute implements EventRun<Runnable> { ...@@ -12,6 +14,7 @@ public class RunExecute implements EventRun<Runnable> {
* @param t 接口 需要执行的对象 * @param t 接口 需要执行的对象
* @throws Exception 跑出异常 * @throws Exception 跑出异常
*/ */
@Override
public void Execute(Runnable t) { public void Execute(Runnable t) {
t.run(); t.run();
} }
......
...@@ -212,6 +212,7 @@ public abstract class ThreadList<T extends Object> implements ThreadWaitExecute ...@@ -212,6 +212,7 @@ public abstract class ThreadList<T extends Object> implements ThreadWaitExecute
* *
* @return * @return
*/ */
@Override
public boolean isFinally() { public boolean isFinally() {
if (this.isWait()) { if (this.isWait()) {
return false; return false;
...@@ -227,6 +228,7 @@ public abstract class ThreadList<T extends Object> implements ThreadWaitExecute ...@@ -227,6 +228,7 @@ public abstract class ThreadList<T extends Object> implements ThreadWaitExecute
* *
* @description * @description
*/ */
@Override
public void printStatus() { public void printStatus() {
int size = cache.size() + cacheThread.size(); int size = cache.size() + cacheThread.size();
String str = String.format("%s 已处理: %d 错误: %d 剩余: %d 后暂停", DateHelper.getNow(), String str = String.format("%s 已处理: %d 错误: %d 剩余: %d 后暂停", DateHelper.getNow(),
...@@ -239,6 +241,7 @@ public abstract class ThreadList<T extends Object> implements ThreadWaitExecute ...@@ -239,6 +241,7 @@ public abstract class ThreadList<T extends Object> implements ThreadWaitExecute
* *
* @return * @return
*/ */
@Override
public int printTimeout() { public int printTimeout() {
return PrintTimeout; return PrintTimeout;
} }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment