我正在设计一个系统，其中有一个主要的对象流和多个工人，这些工人从该对象生成一些结果。最后，有一些特殊/独特的工人（在图论术语中类似于“汇点”），它获取所有结果，并将它们处理为某个最终对象，该对象被写入某个数据库。 一个工人可能依赖于另一些工人的结果（因此等待其结果）。 现在，我面临着几个问...