|
|
|
@ -148,6 +148,7 @@ public class JobThread extends Thread{
|
|
|
|
}
|
|
|
|
}
|
|
|
|
});
|
|
|
|
});
|
|
|
|
futureThread = new Thread(futureTask);
|
|
|
|
futureThread = new Thread(futureTask);
|
|
|
|
|
|
|
|
futureThread.setName(getName());
|
|
|
|
futureThread.start();
|
|
|
|
futureThread.start();
|
|
|
|
|
|
|
|
|
|
|
|
Boolean tempResult = futureTask.get(triggerParam.getExecutorTimeout(), TimeUnit.SECONDS);
|
|
|
|
Boolean tempResult = futureTask.get(triggerParam.getExecutorTimeout(), TimeUnit.SECONDS);
|
|
|
|
|