如果我必须在演员内部进行睡眠/等待活动,例如从阻塞队列中取出,是否有任何问题?
我的用例:我们正在实现一个基本的 ETL,它接收来自异构源(文件、短信、电子邮件)的数据。我们有源特定的接收器,可以触发事件的提取-转换-加载序列流。我们正在使用 Akka Actor 编排流程(主要是为了实现并行性和故障处理/重试)。
对于作为“拉”接收器的文件和电子邮件,在收到事件时会触发一个新流。对于 sms,它是一个“推送”接收器,我们计划有一个单一的流,它的提取器将监听一个持久队列,并且接收器实际上会在事件接收时排队。
我们正在使用 fork-join 调度程序和单个 etl 演员。