我试图使用多个处理器类在处理器步骤中处理记录。这些类可以并行工作。目前,我已经编写了一个多线程步骤,其中我
现在,只要我通过添加taskExecutor使我的工作并行;我就会遇到问题,因为步骤1中设置的输入对象在步骤2中被重写,处理器被用覆盖值调用。我试图搜索是否可以编写组合处理器,将任务并行地委托给多个步骤,但它们只能按顺序工作。
任何投入都会有很大帮助。谢谢!
发布于 2017-10-02 15:50:00
欢迎来到并发。当你不走那条让你置身于安全的决定论世界的道路时,你就会陷入麻烦。如果使用纯函数,则可以消除所有问题。因为在您的函数中没有任何副作用,所以所有变量都应该是最终变量,如果坚持这样做,您将不会遇到任何并发问题。通常,不要使用Java附带的线程库。您应该将线程池和执行器等视为资源。可能应该阅读一下并发性、锁、易失性变量,为什么这些较低级别的构造很难使用,然后再看看更高的结构,比如承诺、未来和参与者。
https://stackoverflow.com/questions/46534241
复制相似问题