Erlang并发编程介绍_Erlang

Erlang中的process——进程是轻量级的,并且进程间无共享。查了很多资料,似乎没人说清楚轻量级进程算是什么概念,继续查找中。。。闲话不提,进入并发编程的世界。本文算是学习笔记,也可以说是《Concurrent Programming in ERLANG》第五张的简略翻译。

1.进程的创建

    进程是一种自包含的、分隔的计算单元,并与其他进程并发运行在系统中,在进程间并没有一个继承体系,当然,应用开发者可以设计这样一个继承体系。
    进程的创建使用如下语法:

复制代码 代码如下:

Pid = spawn(Module, FunctionName, ArgumentList)

spawn接受三个参数:模块名,函数名以及参数列表,并返回一个代表创建的进程的标识符(Pid)。
如果在一个已知进程Pid1中执行:

复制代码 代码如下:

Pid2 = spawn(Mod, Func, Args)

那么,Pid2仅仅能被Pid1可见,Erlang系统的安全性就构建在限制进程扩展的基础上。

2.进程间通信

    Erlang进程间的通信只能通过发送消息来实现,消息的发送使用!符号:

复制代码 代码如下:

Pid ! Message

    其中Pid是接受消息的进程标记符,Message就是消息。接受方和消息可以是任何的有效的Erlang结构,只要他们的结果返回的是进程标记符和消息。
    消息的接受是使用receive关键字,语法如下:
 
复制代码 代码如下:

receive
      Message1 [when Guard1] ->
          Actions1 ;
      Message2 [when Guard2] ->
          Actions2 ;

end

    每一个Erlang进程都有一个“邮箱”,所有发送到进程的消息都按照到达的顺序存储在“邮箱”里,上面所示的消息Message1,Message2,当它们与“邮箱”里的消息匹配,并且约束(Guard)通过,那么相应的ActionN将执行,并且receive返回的是ActionN的最后一条执行语句的结果。Erlang对“邮箱”里的消息匹配是有选择性的,只有匹配的消息将被触发相应的Action,而没有匹配的消息将仍然保留在“邮箱”里。这一机制保证了没有消息会阻塞其他消息的到达。
    消息到达的顺序并不决定消息的优先级,进程将轮流检查“邮箱”里的消息进行尝试匹配。消息的优先级别下文再讲。

    如何接受特定进程的消息呢?答案很简单,将发送方(sender)也附送在消息当中,接收方通过模式匹配决定是否接受,比如:
 

复制代码 代码如下:

Pid ! {self(),abc}

给进程Pid发送消息{self(),abc},利用self过程得到发送方作为消息发送。然后接收方:

复制代码 代码如下:

receive
  {Pid1,Msg} ->

end

通过模式匹配决定只有Pid1进程发送的消息才接受。

3.一些例子
    仅说明下书中计数的进程例子,我添加了简单注释:

复制代码 代码如下:

-module(counter).
-compile(export_all).
% start(),返回一个新进程,进程执行函数loop
start()->spawn(counter, loop,[0]).
% 调用此操作递增计数
increment(Counter)->
    Counter!increament.
% 返回当前计数值
value(Counter)->
    Counter!{self(),value},
    receive
        {Counter,Value}->
            %返回给调用方
            Value
        end.
  %停止计数     
 stop(Counter)->
     Counter!{self(),stop}.
 loop(Val)->
     receive
         %接受不同的消息,决定返回结果
         increament->
             loop(Val+1);
         {From,value}->
             From!{self(),Val},
             loop(Val);
         stop->
             true;
         %不是以上3种消息,就继续等待
         Other->
             loop(Val)
      end.  

调用方式:

复制代码 代码如下:

1> Counter1=counter:start().
<0.30.0>
2> counter:value(Counter1).
0
3> counter:increment(Counter1).
increament
4> counter:value(Counter1).
1

基于进程的消息传递机制可以很容易地实现有限状态机(FSM),状态使用函数表示,而事件就是消息。具体不再展开

4.超时设置

    Erlang中的receive语法可以添加一个额外选项:timeout,类似:

复制代码 代码如下:

receive
   Message1 [when Guard1] ->
     Actions1 ;
   Message2 [when Guard2] ->
     Actions2 ;
  
   after
      TimeOutExpr ->
         ActionsT
end

after之后的TimeOutExpr表达式返回一个整数time(毫秒级别),时间的精确程度依赖于Erlang在操作系统或者硬件的实现。如果在time毫秒内,没有一个消息被选中,超时设置将生效,也就是ActionT将执行。time有两个特殊值:

1)infinity(无穷大),infinity是一个atom,指定了超时设置将永远不会被执行。
2) 0,超时如果设定为0意味着超时设置将立刻执行,但是系统将首先尝试当前“邮箱”里的消息。

超时的常见几个应用,比如挂起当前进程多少毫秒:

复制代码 代码如下:

sleep(Time) ->
  receive
    after Time ->
    true
end.

  比如清空进程的“邮箱”,丢弃“邮箱”里的所有消息:
 

复制代码 代码如下:

 
flush_buffer() ->
  receive
    AnyMessage ->
      flush_buffer()
  after 0 ->
    true
end.

    将当前进程永远挂起:

复制代码 代码如下:

  suspend() ->
    receive
    after
        infinity ->
            true
    end.

    超时也可以应用于实现定时器,比如下面这个例子,创建一个进程,这个进程将在设定时间后向自己发送消息:

复制代码 代码如下:

-module(timer).
-export([timeout/2,cancel/1,timer/3]).
timeout(Time, Alarm) ->
   spawn(timer, timer, [self(),Time,Alarm]).
cancel(Timer) ->
   Timer ! {self(),cancel}.
timer(Pid, Time, Alarm) ->
   receive
    {Pid,cancel} ->
       true
   after Time ->
       Pid ! Alarm
end.

5、注册进程
    为了给进程发送消息,我们需要知道进程的Pid,但是在某些情况下:在一个很大系统里面有很多的全局servers,或者为了安全考虑需要隐藏进程Pid。为了达到可以发送消息给一个不知道Pid的进程的目的,我们提供了注册进程的办法,给进程们注册名字,这些名字必须是atom。
    基本的调用形式:

复制代码 代码如下:

register(Name, Pid)

将Name与进程Pid联系起来

复制代码 代码如下:

unregister(Name)

取消Name与相应进程的对应关系。

复制代码 代码如下:

whereis(Name)

返回Name所关联的进程的Pid,如果没有进程与之关联,就返回atom:undefined

复制代码 代码如下:

registered()

返回当前注册的进程的名字列表

6.进程的优先级

设定进程的优先级可以使用BIFs:

复制代码 代码如下:

process_flag(priority, Pri)

Pri可以是normal、low,默认都是normal
优先级高的进程将相对低的执行多一点。

7.进程组(process group)
    所有的ERLANG进程都有一个Pid与一个他们共有的称为Group Leader相关联,当一个新的进程被创建的时候将被加入同一个进程组。最初的系统进程的Group Leader就是它自身,因此它也是所有被创建进程及子进程的Group Leader。这就意味着Erlang的进程被组织为一棵Tree,其中的根节点就是第一个被创建的进程。下面的BIFs被用于操纵进程组:

group_leader()
返回执行进程的Group Leader的Pid

group_leader(Leader, Pid)
设置进程Pid的Group Leader为进程的Leader

8.Erlang的进程模型很容易去构建Client-Server的模型,书中有一节专门讨论了这一点,着重强调了接口的设计以及抽象层次的隔离问题,不翻译了。

时间: 2024-10-27 08:10:16

Erlang并发编程介绍_Erlang的相关文章

Python并发编程介绍及实例应用

关于Python并发编程的知识,本文基本介绍到位,想深入学习Python的朋友可以参考一下. Python并发简介 我们将一个正在运行的程序称为进程.每个进程都有它自己的系统状态,包含内存状态.打开文件列表.追踪指令执行情况的程序指针以及一个保存局部变量的调用栈.通常情况下,一个进程依照一个单序列控制流顺序执行,这个控制流被称为该进程的主线程.在任何给定的时刻,一个程序只做一件事情. 一个程序可以通过Python库函数中的os或subprocess模块创建新进程(例如os.fork()或是sub

Erlang入门(二)—并发编程

Erlang中的process--进程是轻量级的,并且进程间无共享.查了很多资料,似乎没人说清楚轻量级进程算是什么概念,继续查找中...闲话不提,进入并发编程的世界.本文算是学习笔记,也可以说是<Concurrent Programming in ERLANG>第五张的简略翻译. 1.进程的创建     进程是一种自包含的.分隔的计算单元,并与其他进程并发运行在系统中,在进程间并没有一个继承体系,当然,应用开发者可以设计这样一个继承体系.     进程的创建使用如下语法: Pid = spaw

Erlang中的并发程序简介_Erlang

Erlang中基本的并发函数 1)  Pid =spwan(Mod,Func,Args) 创建一个新的进程来执行apply(Mod,Func,Args),与调用进程并列运行,会使用最新的代码定义模块. 2)  Pid!Message 向Pid进程异步发送Message,!为发送操作符 3)  Receive - end 接收消息 复制代码 代码如下:  receive            Pattern1[when Guard1]-> Expression1;            Patte

《C++ 并发编程》- 第1章 你好,C++的并发世界

本文是<C++ 并发编程>的第一章感谢人民邮电出版社授权并发编程网发表此文版权所有请勿转载.该书将于近期上市. 本章主要内容 何谓并发和多线程  为什么要在应用程序中使用并发和多线程  C++并发支持的发展历程  一个简单的C++多线程程序是什么样的 这是C++用户的振奋时刻.距1998年初始的C++标准发布13年后C++标准委员会给予程序语言和它的支持库一次重大的变革.新的C++标准也被称为C++11或C++0x于2011年发布并带来了很多的改变使得C++的应用更加容易并富有成效. 在C++

C++11 并发编程指南——前言

开场白:前一段时间(大概在8月初)开始写 <C++11 并发编程指南>(最早更新于:http://www.cnblogs.com/haippy),但是由于个人能力有限,加上 9 月初到现在一直在忙着找工作(革命尚未成功),精力有限,难免出现错误,希望读者不吝指正. 另外,这是我在并发编程网上写的第一篇文章,终于迈开了第一步.受@腾飞同学的鼓励,后续我会在本站持续更新与 C++ 并发编程(尤其是C++11并发编程)相关的文章,但由于个人水平有限,希望读者指出我的错误,并多多包涵 最后,个人一直在

Python中利用生成器实现的并发编程

  这篇文章主要介绍了简单介绍Python中利用生成器实现的并发编程,使用yield生成器函数进行多进程编程是Python学习进阶当中的重要知识,需要的朋友可以参考下 我们都知道并发(不是并行)编程目前有四种方式,多进程,多线程,异步,和协程. 多进程编程在python中有类似C的os.fork,当然还有更高层封装的multiprocessing标准库,在之前写过的python高可用程序设计方法中提供了类似nginx中master process和worker process间信号处理的方式,保

《GO并发编程实战》—— 原子操作

声明:本文是<Go并发编程实战>的样章,感谢图灵授权并发编程网站发布样章,禁止以任何形式转载此文. 我们已经知道,原子操作即是进行过程中不能被中断的操作.也就是说,针对某个值的原子操作在被进行的过程当中,CPU绝不会再去进行其它的针对该值的操作.无论这些其它的操作是否为原子操作都会是这样.为了实现这样的严谨性,原子操作仅会由一个独立的CPU指令代表和完成.只有这样才能够在并发环境下保证原子操作的绝对安全. Go语言提供的原子操作都是非侵入式的.它们由标准库代码包sync/atomic中的众多函

我为什么喜欢用C#来做并发编程

题记:就语言和运行时层面,C#做并发编程一点都不弱,缺的是生态和社区. 硅谷才女朱赟(我的家门)昨天发了一篇文章<为什么用 Java -- 关于并发编程>,让大家学习了Java中如何进行并发编程的一些基本知识.作为一个将近15年的.NET程序员,我觉得有必要给大家补充介绍一下C#进行并发编程的知识(当然不会太深入讲解).这篇文章无意进行技术比较,毕竟技术只是工具(大同小异,各有千秋),主要还是看用工具的人. 并发(英文Concurrency),其实是一个很泛的概念,字面意思就是"同时

Java并发编程相关面试问题

基础概念 1.什么是原子操作?在Java Concurrency API中有哪些原子类(atomic classes)? 原子操作(atomic operation)意为"不可被中断的一个或一系列操作" .处理器使用基于对缓存加锁或总线加锁的方式来实现多处理器之间的原子操作. 在Java中可以通过锁和循环CAS的方式来实现原子操作. CAS操作--Compare & Set,或是 Compare & Swap,现在几乎所有的CPU指令都支持CAS的原子操作. 原子操作是