Actor模型

Actor由状态（State）、邮箱（Mailbox）和行为（Behavior）组成。

NewLife.Model.Actor 设计为一个轻量级Actor模型，麻雀虽小五脏俱全！

/// <summary>无锁并行编程模型</summary>
/// <remarks>
/// 独立线程轮询消息队列，简单设计避免影响默认线程池。
/// 适用于任务颗粒较大的场合，例如IO操作。
/// </remarks>
public interface IActor
{/// <summary>添加消息，驱动内部处理</summary>/// <param name="message">消息</param>/// <param name="sender">发送者</param>/// <returns>返回待处理消息数</returns>Int32 Tell(Object message, IActor sender = null);
}

IActor 接口设计为只有一个Tell方法，用于传递要发通知给目标Actor。这里的message可以列极为状态（State）。目标Actor内部有个队列收集信息，该队列可以认为是邮箱（Mailbox）。Actor内部有独立线程去读取邮箱数据进行处理，即是行为（Behavior）！

从某种程度上来讲，Actor就是一个队列加上独立线程。如果该队列设计为分布式队列，那么这个Actor就成了真正的分布式并行模型。（如果Actor配上RedisQueue又会怎么样呢？）

Actor可以一个接着一个，串联起来，形成分布式并发处理集群。尽管是分布式系统，然而所有代码完全不需要考虑多线程问题。

总之，Actor模型的理念非常简单：万物皆Actor！

应用例程

我们来看一段测试代码，默认读取数据库然后生成Excel文件，两步都是比较耗时的操作。

[Fact]
public async void Test1()
{var sw = Stopwatch.StartNew();var actor = new BuildExcelActor();for (var i = 0; i < 6; i++){// 模拟查询数据，耗时500msXTrace.WriteLine("读取数据……");await Task.Delay(500);// 通知另一个处理器actor.Tell($"数据行_{i + 1}");}// 等待最终完成actor.Stop();sw.Stop();Assert.True(sw.ElapsedMilliseconds > 6 * 500);Assert.True(sw.ElapsedMilliseconds < 6 * 500 + 500);
}
private class BuildExcelActor : Actor
{protected override async Task ReceiveAsync(ActorContext context){XTrace.WriteLine("生成Excel数据：{0}", context.Message);await Task.Delay(500);}
}

新建一个实现类继承Actor，重写ReceiveAsync，实现Actor行为（业务逻辑）。此时独占线程，所以无需考虑多线程问题。

跑起来看看日志输出