在已有的多线程环境中使用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(); 
      } 
     } 
    } 
}