如何运行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) { 
     } 
    } 

}