使用演员池有意义吗？
我只是在学习，真的很喜欢，Actor模式。我现在使用Scala，但我对建筑风格感兴趣，因为它用于Scala，Erlang，Groovy等。 案例I “我想要的是我需要同时做事情，例如，让我们说”运行一份工作“。 使用线程，我将创建一个线程池和一个阻塞队列，并让每个线程轮询阻塞队列，并处理作业进入和退出队列。 与演员，什么是最好的方法来处理这个？是否有意义创建一个演员池，并以某种方
..
actor相关内容
如何在Scala中使用actors时限制并发性？
我来自Java，我将 Runnable 提交到由线程支持的 ExecutorService 池。在Java中很清楚如何设置线程池大小的限制。 我对使用Scala演员感兴趣，但我不清楚如何限制并发。 让我们假设，我创建一个接受“jobs”的web服务。使用 POST 请求提交作业，并且我希望我的服务将该作业排入队列，然后立即返回 202接受 - ie 如果我使用actors来处理队
..
从Java并发迁移到Scala并发
我在Java中有一个相当标准的机制来解决问题： 工作项目必须安排在特定时间执行 每个工作项目必须等待条件成为真实 工作项目应可取消 我使用的解决方案如下： 有一个单线程调度程序来安排我的工作 有 ExecutorService （可能是多线程的） 然后将实际工作提交给 ExecutorService 。返回的 Future 被缓存在地图中。完成服务用于在工作完成时从缓存中
..
使用Actors而不是`synchronized'
每次我阅读关于在Scala中使用同步时，作者通常会提到应该使用Actors（例如）。虽然我大致了解演员的工作，我真的想看到的演员被用来替换Java的同步方法修改器的一个例子（这里我的意思是它的Scala等效 - code> synchronized block）。修改数据结构的内部实例将是很高兴看到。 这是对演员的好用还是我误导了？ 解决方案 Actor保证只有一个消息在时间处理，所
..
Akka演员：需要一个例子来了解一些基础知识
我正在修补Akka，并需要一些建议如何实现我想到的具体。我想有一个演员，我可以发送 DownloadFile（URI，文件）消息，并下载它。由于这可以并行，我不想下载文件后文件，但有并发下载的限制。 使用Akka建模的方法是什么？其他的事情，想到的是：如果一个“工人”的演员因某种原因死亡会发生什么？如何重试下载？等等。 我知道这是一个非常巨大的问题，但我希望有人花时间回答它！谢谢！
..
在生成和杀死进程时，F＃真的比Erlang快吗？
更新：此问题包含一个错误，使基准测试无意义。我将尝试比较F＃和Erlang的基本并发功能的更好的基准，并在另一个问题中查询结果。 我试图了解性能特征Erlang和F＃。我发现Erlang的并发模型非常有吸引力，但我倾向于使用F＃的互操作性原因。虽然开箱即用F＃不提供像Erlang的并发原语 - 从我可以告诉异步和MailboxProcessor只覆盖了一小部分Erlang做得很好 - 我一直
..
Actor与线程相比如何工作？
与主题相比，演员有什么好的和简短的解释吗？ 线程不能被视为演员并发送消息到其他线程？我看到一些区别，但对我来说不是很清楚。 解决方案 演员模型对消息操作通过。允许单个进程（actor）异步地相互发送消息。与我们通常认为的线程模型不同的是，（理论上至少）没有共享状态。如果一个人认为（合理地，我认为）共享的国家是所有邪恶的根源，那么演员模型变得非常有吸引力。 我们不应该过度兴奋，但
..
AKKA如何为单个actor提供并发性？
我已读过 “Akka确保每个actor的实例都运行在自己的轻量级线程中，并且其消息一次处理一个。” 如果这是AKKA actors按顺序处理其消息的情况，那么AKKA如何为单个Actor提供并发性。 请帮助。 解决方案 Actors是计算的独立代理，每个执行严格依次，但许多actors可以并发执行。你可以查看一个Actor作为线程，它只花费正常线程的0.1％，并且还有一个
..
如何实现没有Akka的actor模型？
如何实现没有Akka的简单actors？我不需要高性能许多（非固定计数）actor实例，绿线程，IoC（生命周期，基于Props的工厂，ActorRef的），监督，背压等。只需要顺序（队列）+处理程序+状态+消息传递。 作为副作用，我实际上需要小的基于actor的管道（使用递归链接）+一些parallell演员来优化 DSP 算法计算。它将在库内没有传递依赖，所以我不想（而不能作为一个jar
..
阻止Akka Actors中的呼叫
作为一个新手，我想了解演员如何工作。并且，从文档，我想我明白，演员是在同步模式下执行的对象，并且actor执行可以包含阻塞/同步方法调用，例如。 db请求 但是，我不明白的是，如果你写一个在其中有一些阻塞调用（如阻塞查询执行）的actor，整个线程池（在某种意义上cpu的利用率会下降等等），对吧？我的意思是，从我的理解，没有办法JVM理解是否可以切换到别人，如果/当演员进行阻塞调用时。
..
任何好的执行的C＃的演员？
对于.net / c＃， actors并发模型有什么好的实现吗？ 我必须优化一个c＃例程，我认为actors模型完全适合我的问题的解决方案。不幸的是我只有使用scala实现的经验。 解决方案 你应该看看MS 并发&协调运行时（CCR）和分散式软件服务（DSS） ，机器人工作室的一部分 这些框架将允许您开发松散耦合的服务，以满足大多数的actor-approach要求。 A
..
消息传递并发库C？
我一直在找，但我似乎找不到一个消息传递并发（Actor）C（不是C + +）库。理想情况下，候选人将基于类似libevent的东西，允许在大多数地方的非阻塞I / O。有没有人知道这样的图书馆？ 我知道MPI和它的ilk，但这不是我要找的。我正在寻找更多符合 Theron （适用于C ++）或 Kilim （for Java）。 解决方案 0MQ怎么样？ 在此处输入信息：
..
如何处理Scala未来中抛出的异常？
我一直在处理我的答案是否有一个标准的Scala函数用于运行块超时？如果在未来抛出异常，就会遇到问题。 def runWithTimeout [T]（timeoutMs：Long） （f：=> T）：选项[T] = { awaitAll（timeoutMs，future（f））head.asInstanceOf [Option [T]] } 因此 runWit
..
Scala final vs val用于并发可见性
在Java中，当跨多个线程（一般来说）使用对象时，最好将字段设置为final。例如， public class ShareMe { private final MyObject obj; public ShareMe（MyObject obj）{ this.obj = obj; } } 在这种情况下，obj的可见性将是一致的 在scala中，它不会出
..
Scala actors可以同时处理多个消息吗？
对我最近的一个问题的回复一个actor一次处理一个 消息。这是真的？我没有看到任何明确说明（在 中的编程），其中包含以下代码段（第593页） 如果[ react 方法]找到可以处理的邮件，[it]会安排处理该邮件以供日后执行并抛出异常 （强调我自己）。两个相关（和相互排斥的）问题： 假设一个actor可以同时处理多个消息，我如何强制actor处理消息1 （如果这是我想做的）？ （
..
哪个Actor模型库/框架Java？
有许多不同的 Actor模型实现Java（和JVM语言）。 许多Actor库和框架已经实现，以允许在Java中进行Actor风格的编程（没有内置的Actor）。我认为Actor模型有很大的优势，但是Java的选择是压倒性的！ 有人可以发布最流行的模型，并提供一些洞察力使用哪些？根据每秒传递的消息，哪些类型具有吞吐量基准？ 解决方案 这是一个很好的文章系列。另请参阅此演示文稿。
..
LMAX的干扰器模式如何工作？
我想了解干扰器模式。我看了InfoQ的视频，试图阅读他们的论文。我理解有一个环形缓冲区涉及，它被初始化为一个极大的数组，以利用缓存局部性，消除新的内存分配。 这听起来像是有一个或多个原子整数跟踪位置。每个“事件”似乎获得一个唯一的id，它在环中的位置是通过找到其相对于环的大小等的模数找到的。 不幸的是，我没有直观的感觉如何工作。我做了许多交易应用程序，并研究了演员模型，看着SEDA等。
..
与Actor一起使用时的Scala变量绑定
我对Scala很新。 我试图理解如何/如果scala在闭包作为消息的一部分传递给Actor时进行动态绑定。 我使用Akka 1.2和Scala 2.9。 我有以下代码段（修改自
..
演员模型：为什么erlang特别？或者，你为什么需要另一种语言呢？
我一直在寻找学习erlang，因此，一直在阅读（好，撇去）关于演员模型。 从我的理解， actor模型只是一组函数（在erlang中称为“processes”的轻量级线程中运行），它们仅通过消息传递来相互通信。 在C ++或任何其他语言中实现： class BaseActor { std :: queue ;消息; CriticalSect
..
TPL数据流，怎么着大量链接的目标块中的项目只有一个特定的目标块？
我要寻找可持有多单的项目，它可以链接到多个目标块多TPL数据流块解决方案，但其中有一个项目转交只有通过过滤器的特定目标块的能力/谓词。在任何时候都不能的项目的同时被输送到多个目标块，始终只对其中一个相匹配的滤波器或项可以被丢弃。我不喜欢BroadCastBlock的，因为，如果我理解正确的话，它不保证交付（或做它？）和滤波对象块端完成，这意味着BroadCastBlock本质上发送的每个项目的副本
..