|
@@ -133,17 +133,18 @@ public class MDO0039Service extends MDO0039BaseModel implements ExecProcessFlow
|
|
|
LogService.addLog(pid,"求解——————————————————开始");
|
|
|
DockerExe.stopDocker(pid);
|
|
|
DockerExe.runMdo2(pid);
|
|
|
- int con=0;
|
|
|
+ final int[] con = {0};
|
|
|
final String[] line = {""};
|
|
|
CompletableFuture<Void> cf = CompletableFuture.supplyAsync(()-> {try {
|
|
|
DockerExe.getDockerLogs(pid,new ResultCallback.Adapter<Frame>() {
|
|
|
@Override
|
|
|
public void onNext(Frame frame) {
|
|
|
- if(con <100){
|
|
|
+ if(con[0] <100){
|
|
|
line[0]+=new String(frame.getPayload());
|
|
|
}else{
|
|
|
LogService.addLog(pid, line[0]);
|
|
|
line[0]="";
|
|
|
+ con[0] =0;
|
|
|
}
|
|
|
System.out.print(new String(frame.getPayload()));
|
|
|
super.onNext(frame);
|