我正在尝试在Java8中创建带有流的一个生产者多消费者模型。我正在读取和处理来自DB资源的数据,我想以流的方式处理它们(不能将整个资源读取到内存中)。我还没有发现如何使用并行流处理来连接(互连)非并行流。有没有什么办法可以用Java8 stream API来实现呢?此迭代器必须在单线程中运行,因为游标不是线程安全的。cursor.hasNext(); public Data next() {
如何在Java8中对此进行优化?优化是我首先关注的问题。已尝试使用Java8 streams和并行流。但是在Java8流中的foreach循环中不允许终止(Break)。code to process if(employee.getLastname().equals("xxx")) { }在Java8