如何運行3種方法同時或並行使用Java 8流

Question

1）熱衷於我們運行方法1，2,3平行如何使用Java 8

2知道）這是不是正確的方式，以滿足我的要求用java 8使用流？

public void RunParallel() 
{ 
    String method1 = method1(); 
    String method2 = method2(); 
    String method3 = method3(String Value); 
} 

Stream.<Runnable>of(() -> method1(),() -> method2(),() -> method3()).parallel().forEach(Runnable::run);

Answer 1

你可以使用Java 8以下，用下面的代碼方法1，方法2並行&方法3運行。如果你想在所有完成之後做一些事情，那麼你可以使用future.get（）;

public void RunParallel() 
{ 
    CompletableFuture<Void> future1 = CompletableFuture.runAsync(()->{ 
     String method1 = method1(); 
    }); 

    CompletableFuture<Void> future2 = CompletableFuture.runAsync(()->{ 
     String method2 = method2(); 
    }); 

    CompletableFuture<Void> future3 = CompletableFuture.runAsync(()->{ 
     String method3 = method3("some inp"); 
    }); 

    CompletableFuture<Void> future = CompletableFuture.allOf(future1, future2, future3); 
    try { 
     future.get(); // this line waits for all to be completed 
    } catch (InterruptedException | ExecutionException e) { 
     // Handle 
    } 
} 

Answer 2

爲要並行這樣運行的每個不同的方法擴展Thread類：

public static void main(String[] args) { 
    new Operation1().start(); 
    new Operation2().start(); 
    ... 
} 

public class Operation1 extends Thread{ 
    public Operation1() { 
     super("Operation1"); 
    } 
    @Override 
    public void run() { 
     method1(); 
    } 
} 
public class Operation2 extends Thread{ 
... 
} 

Answer 3

很簡單並行

Thread thread1=new Thread() { 
    public void run() { 
     method1(); 
    } 
}; 
thread1.start(); 

重複運行的方法，這對所有的方式你剩下的方法。

下面是你的示例代碼。這裏所有三個線程並行執行相應的方法。

public class ThreadTest1 { 

    public static void main(String[] args) { 
     // TODO Auto-generated method stub 

     Thread thread1 = new Thread() { 
      public void run() { 
       method1(); 
      } 
     }; 
     thread1.start(); 

     Thread thread2 = new Thread() { 
      public void run() { 
       method2(); 
      } 
     }; 
     thread2.start(); 

     Thread thread3 = new Thread() { 
      public void run() { 
       method3(); 
      } 
     }; 
     thread3.start(); 

    } 

    static void method1() { 

     try { 
      while(true){ 
      System.out.println("test1"); 
      Thread.currentThread().sleep(1000); 
      } 
     } catch (InterruptedException e) { 
     } 
    } 

    static void method2() { 
     try { 
      while(true){ 
      System.out.println("test2"); 
      Thread.currentThread().sleep(1000); 
      } 
     } catch (InterruptedException e) { 
     } 
    } 

    static void method3() { 
     try { 
      while(true){ 
      System.out.println("test3"); 
      Thread.currentThread().sleep(1000); 
      } 
     } catch (InterruptedException e) { 
     } 
    } 

}