在已有的多線程環境中使用Java Stream API

Question

我的應用程序有自己的線程池（myThreadPool），我正在分配它的一個線程（Producer）來通過java stream API讀取文件。但是在運行時，流在某處丟失，永遠不會達到打印方法。但是當我在單線程環境中運行流時，它可以工作。是否發生這種情況是因爲java流Api在其底下使用了自己的線程池，或者這在概念上是錯誤的？

public class Processor { 

    public void process() { 
    ExecutorService myThreadPool = Executors.newFixedThreadPool(3); 
    myThreadPool.execute(new Producer()); 
    } 

    private class Producer implements Runnable{ 
    @Override 
    public void run() { 
     try (Stream<String> lines = Files.lines(Paths.get("Path"))) { 
      System.out.println(lines.count()); 
     } catch (IOException e) { 
      e.printStackTrace(); 
     } 
    } 
} 
} 

Answer 1

我不知道你發生了什麼。但我可以給你一個建議（也許你的程序退出了，生產者沒有終止）。複製這段代碼，看看你的代碼有什麼問題。

public class Processor { 

    public void process() { 
     ExecutorService myThreadPool = Executors.newFixedThreadPool(3); 
     try { 
      myThreadPool.execute(new Producer()); 
      Thread.currentThread().join(); 
     } catch (Exception ex) { 
      ex.printStackTrace(); 
     } 
    } 

    private class Producer implements Runnable { 
     @Override 
     public void run() { 
      try (Stream<String> lines = Files.lines(Paths.get("Path"))) { 
       System.out.println(lines.count()); 
      } catch (IOException e) { 
       e.printStackTrace(); 
      } 
     } 
    } 
} 

OR

public class Processor { 

    public void process() { 
     ExecutorService myThreadPool = Executors.newFixedThreadPool(3); 
     try { 
      myThreadPool.submit(() -> { 
       new Producer().run(); 
       return null; 
      }).get(); 
     } catch (Exception ex) { 
      ex.printStackTrace(); 
     } 
    } 

    private class Producer implements Runnable { 
     @Override 
     public void run() { 
      try (Stream<String> lines = Files.lines(Paths.get("Path"))) { 
       System.out.println(lines.count()); 
      } catch (IOException e) { 
       e.printStackTrace(); 
      } 
     } 
    } 
}