管道灾源

src/main/java/com/miniframe/bisiness/system/D00008Service.java

@@ -1,9 +1,11 @@
 package com.miniframe.bisiness.system;
 
 import java.io.BufferedReader;
+import java.io.IOException;
 import java.io.InputStream;
 import java.io.InputStreamReader;
 import java.util.Map;
+import java.util.concurrent.CompletableFuture;
 import java.util.concurrent.ExecutorService;
 import java.util.concurrent.Executors;
 
@@ -33,18 +35,27 @@ public class D00008Service extends D00008BaseModel implements ExecProcessFlow {
 		}
 
 	}
+	//异步执行
 	@SneakyThrows
 	public void exeFier(Integer aid) throws Exception{
-		Runtime runtime = Runtime.getRuntime();
-		Process p =null;
-		p= runtime.exec("sh "+TemplateGenerator.BPATH+"/"+aid+"/"+"runFile.sh");
-		InputStream fis = p.getInputStream();
-		InputStreamReader isr = new InputStreamReader(fis);
-		BufferedReader br = new BufferedReader(isr);
-		String line = null;
-		while ((line = br.readLine()) != null) {
-			System.out.println(line);
-		}
+		CompletableFuture<Void> cf = CompletableFuture.supplyAsync(()->{
+			try {
+			Runtime runtime = Runtime.getRuntime();
+			Process p =null;
+			p= runtime.exec("sh "+TemplateGenerator.BPATH+"/"+aid+"/"+"runFile.sh");
+			InputStream fis = p.getInputStream();
+			InputStreamReader isr = new InputStreamReader(fis);
+			BufferedReader br = new BufferedReader(isr);
+			String line = null;
+			while ((line = br.readLine()) != null) {
+				System.out.println(line);
+			}
+			} catch (IOException e) {
+				e.printStackTrace();
+			}
+			return null;
+		});
+
 	}
 	
 	/**