工作线程和工作流的Cadence配置

Question

将是什么

线程不足，无法执行工作流。如果此消息始终显示，请选择WorkerOptions。应减小maxConcurrentWorklfowExecutionSize或WorkerOptions。maxWorkflowThreads增加。

处于阻塞状态的工作流在内存中保持活动状态？？处于等待状态的工作流是否持续检查条件？？更多的

public class TestWorkflowImpl implements TestWorkflow {

 private static final Logger logger = LoggerFactory.getLogger(TestWorkflow.class);
 private int counter = 0;

 private final CounterPrintActivity cpa = Workflow.newActivityStub(CounterPrintActivity.class);

 @Override
 @WorkflowMethod
 public String startWorkflow() {
 Workflow.await(() ->counter >= 1000);
 return "Complete";
 }

 @Override
 public int getCurrentStatus() {
 return counter;
 }

 @Override
 public void setCount(int setNum) {
 logger.info("In signal");
 counter = counter+setNum;
 }

-

Answer 1

工人和工作流之间的比例是多少，如何管理线程，以便工人和工作流数量之间不应该中断。如果我在抛出错误后开始更多的工作流，

由于被阻止的工作流根本不消耗工作线程内存（在它们被推出缓存之后），因此不存在这样的比率。因此，如果这些工作流没有任何进展，则可能会拥有数十亿个被阻止的工作流和单个工作人员。

线程不足，无法执行工作流。如果此消息始终显示，请选择WorkerOptions。应减小maxConcurrentWorklfowExecutionSize或WorkerOptions。maxWorkflowThreads增加。

maxWorkflowThreads定义所有当前正在执行和缓存的工作流可以使用的线程数。

< code > maxConcurrentWorklfowExecutionSize 定义可以并行执行多少工作流任务。

“没有足够的线程来执行工作流”异常表明没有足够的线程来执行当前正在运行的工作流任务。例如，如果每个工作流使用两个线程，并且maxConloctWorklfowExecutionSize为100，则maxWorkflow Thread应该至少为200。通过这样的设置，0个工作流将被缓存，因为所有线程都将被当前正在执行的工作流任务消耗。因此，一般来说，最好保持maxConloctWorklfowExecutionSize远高于maxConloctWorklfowExecutionSize以支持缓存。

处于阻塞状态的工作流在内存中保持活动状态？？

它将保持缓存状态，直到另一个工作流需要取得进展并将缓存的工作流踢出。之后，当阻塞的工作流接收到一些新事件（如计时器、信号或活动完成）时，它将被加载到工作线程内存中。

处于等待状态的工作流持续检查条件？？更多处于等待状态的工作流数量将使工作人员保持工作状态？？

它仅在处理某些新事件时进行检查。当什么都没有发生时，不会执行检查。

在下面的示例中，线程正在等待信号，工作流的数量被缩放为一百万/天，timetocloseWorkflow=2天。触发信号的平均时间是相应工作流启动后的1天

假设工作人员可以跟上工作流任务处理速度，则此场景应该可以正常工作。