Actor模式是一种并发模型，与另一种模型共享内存完全相反，Actor模型share nothing。所有的线程(或进程)通过消息传递的方式进行合作，这些线程(或进程)称为Actor。共享内存更适合单机多核的并发编程，而且共享带来的问题很多，编程也困难。随着多核时代和分布式系统的到来，共享模型已经不太适合并发编程，因此几十年前就已经出现的Actor模型又重新受到了人们的重视。MapReduce就是一种典型的Actor模式，而在语言级对Actor支持的编程语言Erlang又重新火了起来，Scala也提供了Actor，但是并不是在语言层面支持，Java也有第三方的Actor包，Go语言channel机制也是一种类Actor模型。

单线程编程

单核单机时代一般都是单线程编程，如果把程序比作一个工厂，那么只有一个工人，这个工人负责所有的事情，所有的原料，工具产品等都放到一个地方，因为只有一个人，因此使用一套工具就行，取原料也不用排队等。

多线程编程-共享内存

到了多核时代，有多个工人，这些工人共同使用一个仓库和车间，干什么都要排队。比如我要从一块钢料切出一块来用，我得等别人先用完。有个扳手，另一个人在用，我得等他用完。两个人都要用一个切割机从一块钢材切一块钢铁下来用，但是一个人拿到了钢材，一个人拿到了切割机，他们互相都不退让，结果谁都干不了活。

假如现在有一个任务，找100000以内的素数的个数，最多使用是个线程，如果用共享内存的方法，可以用下面的代码实现。可以看到，这些线程共享了currentNum和totalPrimeCount，对它们做操作时必须上锁。

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
public class PrimeCount implements Runnable {
    
    private int currentNum = 2;  //从2开始找
    private int totalPrimeCount = 0; //当前已经找到的
     
    //取一个数，不能重复，最大到100000
    private int incrCurrentNum() { 
        synchronized (this) {     //如果不用锁，必然会出错。
            if(currentNum > 100000) {
                return -1;
            } else {
                int result = currentNum;
                currentNum++;
                return result;
            }  
        }
    }
     
   //把某个线程找到的素数个数加上
    private void accPrimeCount(int count) { 
        synchronized (this) {
            totalPrimeCount += count;
        }
    }
     
    @Override
     //一直取数并判断是否为素数，取不到了就把找到的个数累加
    public void run() { 
        int primeCount = 0;
        int num;
        while((num=incrCurrentNum()) != -1) {
            if(isPrime(num)) {
                primeCount++;
            }
        }
        accPrimeCount(primeCount);
    }
    private boolean isPrime(int num) {
        for(int i = 2; i < num; i++) {
            if(num % i == 0) {
                return false;
            }
        }
        return true;
    } 
     
    @SuppressWarnings("static-access")
    public static void main(String[] args){
        PrimeCount pc = new PrimeCount();
        for(int i = 0; i < 10; i++) {
            new Thread(pc).start();
        }
        try {
            Thread.currentThread().sleep(5000);
        } catch (InterruptedException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        System.out.println(pc.getTotalPrimeCount());
    }
     
    public int getTotalPrimeCount() {
        return totalPrimeCount;
    }
  
}

多线程/分布式编程-Actor模型

到了分布式系统时代，工厂已经用流水线了，每个人都有明确分工，这就是Actor模式。每个线程都是一个Actor，这些Actor不共享任何内存，所有的数据都是通过消息传递的方式进行的。

如果用Actor模型实现统计素数个数，那么我们需要1个actor做原料的分发，就是提供要处理的整数，然后10个actor加工，每次从分发actor那里拿一个整数进行加工，最终把加工出来的半成品发给组装actor，组装actor把10个加工actor的结果汇总输出。

用scala实现，下面是工程的结构：

这是它们传递的消息，有一些指令，剩下的都是Int数据:

一个Actor的代码结构一般是下面这种结构，不停的接受消息并处理，没有消息就等待：

组装者代码：

分发者代码：

加工者代码：

主线程代码：

工程代码可以在附件中下载。这个代码实现的效果与前面用Java实现的是一样的，但是各个线程没有共享内存，也没有锁，这样开发起来容易，而且更适合分布式编程，因为分布式编程本身就不适合共享内存。Scala的Actor不能原生的支持分布式，但是Erlang可以，使用Erlang的Actor，分布式编程就和本地编程基本一样。但是Erlang的语法难懂，而且没有变量，几乎所有需要使用循环的地方都得用递归。

本文转自nxlhero 51CTO博客，原文链接：http://blog.51cto.com/nxlhero/1666250，如需转载请自行联系原作者

十分钟理解Actor模式相关推荐

  1. java actor_十分钟理解Actor模式

    Actor模式是一种并发模型,与另一种模型共享内存完全相反,Actor模型share nothing.所有的线程(或进程)通过消息传递的方式进行合作,这些线程(或进程)称为Actor.共享内存更适合单 ...

  2. java弱引用怎么手动释放,十分钟理解Java中的弱引用，十分钟java引用

    十分钟理解Java中的弱引用,十分钟java引用 本篇文章尝试从What.Why.How这三个角度来探索Java中的弱引用,帮助大家理解Java中弱引用的定义.基本使用场景和使用方法.由于个人水平有限 ...

  3. 十分钟理解Transformer

    本文转载于知乎文章:十分钟理解Transformer Transformer是一个利用注意力机制来提高模型训练速度的模型.关于注意力机制可以参看这篇文章,trasnformer可以说是完全基于自注意力 ...

  4. 十分钟理解线性代数的本质_数学对于编程来说到底有多重要？来看看编程大佬眼里的线性代数！...

    本文提出了一种观点:从应用的角度,我们可以把线性代数视为一门特定领域的程序语言.我们一起来看看!文章有点偏理论讨论,可能比较枯燥,对于一名程序员,你如果看下去,你将会有不一样的收获! 线性代数是什么? ...

  5. 漫谈设计模式--3分钟理解桥接模式：笔和画的关系

    其实不需要3分钟,3秒钟就够了,记住桥接模式就是如此简单:一句话,笔有千般形,画有万变化. 下面的仅仅助于理解. 1. 定义 The bridge pattern is a design patter ...

  6. 十分钟理解Java泛型擦除

    泛型信息只存在于代码编译阶段,但是在java的运行期(已经生成字节码文件后)与泛型相关的信息会被擦除掉,专业术语叫做类型擦除. 今天我们来讲解泛型中另一个重要知识点--泛型擦除! 泛型擦除概念 泛型信 ...

  7. 十分钟理解线性代数的本质_复习线性代数的正确方式

    有同学对我讲现在复习线性代数遇到了瓶颈,在历年的复习过程中,有许多同学完全找不到复习的感觉,线性代数这门学科的学习方法和高等数学完全不一样,也就是说你学习线性代数首先你得换学习思想,它完全是一套全新的 ...

  8. 十分钟理解线性代数的本质_“线性代数的本质”整理笔记1

    只能说现在的学习环境实在是太太太又友好了. 第一讲:向量.在线性代数中,向量通常都是从原点出发的箭头,而不是物理中理解的,只要方向和长度相同,向量都是等同的.You should think the ...

  9. 十分钟理解javascript中的this对象

    最近在参加的几场面试中都涉及到了对于js中this对象的理解,那么怎样去理解this呢?这里针对不同的场景通过代码来帮助我们理解好this. this到底指向什么? this指向什么呢?一言以蔽之: ...

  10. 十分钟理解logistic回归原理

    关于逻辑回归的分类算法,很多书籍都有介绍,比较来看,还是**李航老师的书<统计学习方法>**里介绍的更清楚,若大家有时间,请不要偷懒,还是建议从头开始看李航老师的书,这本书简洁明了,适合入 ...

最新文章

  1. Asp.net MVC 3实例学习之ExtShop（二）——创建母版页
  2. JVM的架构和执行过程
  3. jtable根据内容自动调整列宽
  4. LeetCode() Word Search II
  5. 设计模式 总揽 通过这篇随笔可以访问所需要了解的设计模式
  6. [20171120]11G关闭直接路径读.txt
  7. 在springboot中一些框架和插件的配置
  8. linux校园网设计方案,linux在校园网的应用方案.doc
  9. html为知笔记模板,新建笔记模板二次开发
  10. mysql的会话变量,全局变量,状态信息
  11. 软件项目成本估算的基本方法
  12. 【从零开始的SDN学习之路】之闲话Neutron与SDN的联系
  13. YOLOv5桌面应用开发，手把手教学实操（上）——附源代码
  14. flutter报错: [!] Automatically assigning platform `iOS` with version `8.0` on target `Runner` becaus
  15. CSS3 文本多列 分栏
  16. 数据结构课程设计-停车场管理系统
  17. JavaScript生成uuid的四种方法
  18. iframe简单用法
  19. 何宾 单片机原理及应用_STC单片机原理及应用（第2版）
  20. 使用BCG对MFC进行换肤

热门文章

  1. logstash之codec插件
  2. mysql查询条件中使用 或 !-的问题
  3. 关于ftp的被动模式与IPTABLES策略
  4. 运维日常操作--linux命令
  5. 活动目录概念和灾难恢复
  6. 解决“HTTP Error 401 – Unauthorized”
  7. java net 安卓_Java和Android Http连接程序：使用java.net.URL 下载服务器图片到客户端...
  8. FRR BGP协议分析11 -- ZEBRA初始化
  9. DPDK收发包全景分析
  10. TensorFlow入门：计算图和梯度流