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
  {Pid
1, 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的模型,书中有一节专门讨论了这一点,着重强调了接口的设计以及抽象层次的隔离问题,不翻译了
目录
相关文章
|
供应链 安全 物联网
区块链去中心化交易所源码|去中心化交易系统开发
随着区块链技术的发展,应用的扩展,区块链软件开√发也随之应用到物联网、供应链管理等领域,其中包含区块链交Y所系统,区块链去中心化交Y所,依托于区块链技术,具有去中心化、匿名性、信息不可纂改等特点
|
缓存 安全 NoSQL
Spring Cloud实战 | 第六篇:Spring Cloud Gateway+ Spring Security OAuth2 + JWT实现微服务统一认证鉴权
Spring Cloud实战 | 第六篇:Spring Cloud Gateway+ Spring Security OAuth2 + JWT实现微服务统一认证鉴权
Spring Cloud实战 | 第六篇:Spring Cloud Gateway+ Spring Security OAuth2 + JWT实现微服务统一认证鉴权
|
7月前
|
缓存 小程序 前端开发
商城/点餐/家政类小程序源码合集_微信抖音小程序源码开发从入门到精通实战
本文系统讲解如何利用现有源码快速开发商城、点餐、家政类微信/抖音小程序,涵盖环境搭建、核心功能实现、多平台部署与优化,提供完整技术方案。实战导向,助力开发者高效入门与落地。
|
12月前
|
人工智能 自然语言处理 搜索推荐
科技云报到:鏖战企业级市场,AI Agent如何重塑智能商业未来?
Agent“黄金时代”已至,RPA如何搭上这班车?
838 13
|
存储 人工智能 Serverless
方案测评 | 零基础一键AI剧本生成与动画创作
阿里云推出基于AI技术的剧本生成与动画创作解决方案,利用函数计算FC、百炼模型服务和ComfyUI工具,实现从剧本撰写到视频合成的一站式自动化流程。该方案大幅降低动画制作的技术门槛与成本,加速内容生产,帮助创作者快速响应市场变化。通过体验发现,方案在高效性、创新性方面表现突出,但也存在视频生成时间较长、定制化功能不足等问题。整体而言,该方案为动画创作提供了新的可能性,尤其适合初创团队和个人创作者。
|
Oracle 关系型数据库 虚拟化
还在破解VMware?免费了,你知道吗?
VMware 现在对个人用户完全免费!无需破解,轻松使用。Workstation Pro 17.5.2 和 Fusion Pro 13.5.2 已正式发布,快来下载体验吧!下载前需登录 Broadcom Support Portal,注册账号即可。
966 0
|
弹性计算 人工智能 数据安全/隐私保护
【手把手教你】如何免费畅快使用阿里云ECS搭建私有Overleaf论文写作服务
本文详细介绍如何利用阿里云ECS免费搭建私有Overleaf论文写作服务,包括ECS服务器的部署、Overleaf服务的安装、TexLive包的更新、XeLaTeX修复、中文字体支持及账号管理等步骤。通过这些操作,你可以实现免费且高效的多人协作论文写作,避免付费版本的高昂费用。适合需要频繁合作撰写论文的团队使用。
【手把手教你】如何免费畅快使用阿里云ECS搭建私有Overleaf论文写作服务
|
存储 移动开发 程序员
80C51单片机的七种寻址方式
80C51单片机的七种寻址方式
1309 1
|
前端开发 JavaScript 开发者
前端JS按钮点击事件、跳出弹窗、遮罩的实战示例
本文提供了一个前端JS按钮点击事件、弹出式窗口和遮罩层的实战示例,包括HTML、CSS和JavaScript的具体实现代码,以及功能解析,演示了如何实现按钮点击后触发弹窗显示和遮罩层,并在2秒后自动关闭或点击遮罩层关闭弹窗的效果。
前端JS按钮点击事件、跳出弹窗、遮罩的实战示例
|
前端开发 JavaScript 开发者
雪碧图:图片合并的艺术!
雪碧图:图片合并的艺术!