Erlang中的注册进程使用实例

之前看到 Erlang 中的注册进程时，对注册并不理解，主要是不理解注册的原子的作用域。刚才突然想明白了：

代码如下:

注册进程关联的原子具有全局作用域

也就是说关联了注册进程之后的原子可以全局被使用

Erlang 中的并发机制是通过消息邮箱实现的，进程间进行通讯的方式只有消息邮箱，而进程间通讯需要知道进程的进程号，而使用 spawn 产生新进程时会返回新进程的进程号供使用。

一个最简单的进程间通信的程序如下

代码如下:

-module(test).

start() ->
    spawn(?MODULE, loop, []).

loop() ->
    io:format("Waiting for new message.~n"),
    receive
        M -> io:format("New message: ~p~n", [M])
    end,
    loop().

在 Erlang Shell 中使用 c(test) 编译这个模块，之后就可以简单的使用了.

在下面的代码中，语句前面的注释表示解释，语句后面的注释表示输出值， % => 后面的值表示语句的返回值

代码如下:

% 编译这个模块
c(test).

% 开启无限循环
Pid = test:start().
% Waiting for new message.                             % 新进程 spawn 后立刻运行
% => <0.35.0>                                          % 返回新进程的进程号

% 向进程发送消息
Pid ! 'message'.
% New message: message                                 % 接收到消息
% Waiting for new message.                             % 继续接收消息
% => message                                           % 语句返回值，而非进程返回消息

为了用户不用每次都 Pid ! 'message'，可以加入一个 call 方法进行包装一下。

代码如下:

call(Pid, M) ->
    Pid ! M.

这样就可以使用 test:call(Pid, 'message') 发送消息了。

但是这样写还有个明显的弊端，调用 call 时需要 Pid 参数，但是又不能去掉，因为需要进程号才能通信，所以使用时需要用户维护一个进程号。

而 Erlang 提供了注册进程的机制用来把原子关联到进程中，可以解决这个问题

使用 register(atom, Pid) 可以将 atom 关联到进程号为 Pid 的进程上，这个原子就

修改上面的 start 函数为

代码如下:

start() ->
    register(testp, spawn(?MODULE, loop, [])).

这样，新的进程将关联到原子 testp，此时原子就可以当作 Pid 那样使用 "消息发送操作符" !

代码如下:

testp ! 'message'

于是可以修改上面的 call 函数，去掉 Pid 参数，而使用关联后的原子，这个关联后的原子不止在模块内有效，在全局作用域中都是有效的。

代码如下:

call(M) ->
    testp ! M.

因此使用注册进程修改后的程序如下

代码如下:

-module(test).

start() ->
    register(testp, spawn(?MODULE, loop, [])).

loop() ->
    io:format("Waiting for new message.~n"),
    receive
        M -> io:format("New message: ~p~n", [M])
    end,
    loop().

call(M) ->
    testp ! M.

注册相关的 BIF


代码如下:

% 注册 atom 到 Pid

register(atom, Pid).

% 取消 atom 的注册
unregister(atom).

% 返回 atom 关联的进程号，如果未关联，返回 undefined
whereis(atom).

% 返回系统中所有已注册的进程名
registered().

赞 (0)

相关推荐

  • Erlang中的注册进程使用实例

    之前看到 Erlang 中的注册进程时,对注册并不理解,主要是不理解注册的原子的作用域.刚才突然想明白了: 复制代码 代码如下: 注册进程关联的原子具有全局作用域 也就是说关联了注册进程之后的原子可以全局被使用 Erlang 中的并发机制是通过消息邮箱实现的,进程间进行通讯的方式只有消息邮箱,而进程间通讯需要知道进程的进程号,而使用 spawn 产生新进程时会返回新进程的进程号供使用. 一个最简单的进程间通信的程序如下 复制代码 代码如下: -module(test). start() ->  

  • Erlang分布式节点中的注册进程使用实例

    上一篇文章中说到, 注册进程关联的原子具有全局作用域, 这里的全局指的是当前 Erlang 虚拟机, 在分布式中, 便是当前分布式节点. 因此, 在一个节点中注册进程关联的原子, 在另一个节点中是不能直接使用, 而必须配和目标节点使用. 复制代码 代码如下: {RegName, Node} ! {messages}. 例子 先启动一个 Server 节点 复制代码 代码如下: erl -sname server 然后在 Erlang Shell 中操作 先简单介绍几个常用函数 复制代码 代码如下

  • 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;            Patter

  • 详解nodejs中的process进程

    虽然node对操作系统做了很多抽象的工作,但是你还是可以直接和他交互,比如和系统中已经存在的进程进行交互,创建工作子进程.node是一个用于事件循环的线程,但是你可以在这个事件循环之外创建其他的进程(线程)参与工作. 进程模块 process模块允许你获得或者修改当前node进程的设置,不想其他的模块,process是一个全局进程(node主进程),你可以直接通过process变量直接访问它. process实现了EventEmitter接口,exit方法会在当进程退出的时候执行.因为进程退出之

  • Linux 中常用的Rpm命令实例详解

    rpm命令是RPM软件包的管理工具.rpm原本是Red Hat Linux发行版专门用来管理Linux各项套件的程序,由于它遵循GPL规则且功能强大方便,因而广受欢迎.逐渐受到其他发行版的采用.RPM套件管理方式的出现,让Linux易于安装,升级,间接提升了Linux的适用度. 语法 rpm(选项)(参数) 选项 -a:查询所有套件: -b<完成阶段><套件档>+或-t <完成阶段><套件档>+:设置包装套件的完成阶段,并指定套件档的文件名称: -c:只列出

  • Erlang中的函数与流程控制介绍

    一:函数 1:在Erlang中,[名字相同但参数数目不同]的两个函数是完全不同的函数. 2:其他模块内的函数用完全限定名称 被调用: 复制代码 代码如下: -module(sort1). -export([reverse_sort/1, sort/1]). reverse_sort(L) ->         lists1:reverse(sort(L)). sort(L) ->         lists:sort(L). 3:子句间以分号[;]分隔,在最后的结尾处以[.]结尾. 4:每个函

  • Linux 中fork的执行的实例详解

    Linux 中fork的执行的实例详解 先看看一段fork的程序 int main() { pid_t pid; 语句 a; pid = fork(); 语句 b; } 1.当程序运行到 pid = fork()时,这个进程马上分裂(fork的中文意思)成两个进程,我们称为父进程和子进程,子进程是父进程的副本,副本的意思是子进程把父进程的数据空间,堆和栈都复制一遍给自己用,这要求在内存给子进程分配和父进程同样大的存储空间,这样,父,子进程拥有相同的数据,但不会共享存储空间,他们只是共享正文段.

  • IOS 中UIApplication详解及实例

    IOS 中UIApplication详解及实例 以前刚学iPhone开发时,觉得UIApplication这个东西特NB,特神秘,比如它居然能打开一个URL,而且还是用一个很神秘的方法得到实例: [UIApplication sharedApplication] 它对我的神秘感一直保持到今天下午.今天下午负责UI设计的同事在设计,我没有素材,比较清闲,于是发个狠,专门看了一下UIApplication这个类.果然是难者不会,会者不难,看完之后,这个类的神秘感一下子没了.下面让我来揭开它的神秘面纱

  • Spring MVC中自定义拦截器的实例讲解

    Spring MVC中自定义拦截器的实例讲解

    1. 引言 拦截器(Interceptor)实现对每一个请求处理前后进行相关的业务处理,类似于Servlet的Filter. 我们可以让普通的Bean实现HandlerIntercpetor接口或继承HandlerInterceptorAdapter类来实现自定义拦截器. 通过重写WebMvcConfigurerAdapter的addIntercetors方法来注册一个计算每一次请求的处理时间的拦截器. 2. 自定义拦截器的实现 2.1 定义拦截器 新建LogInterceptor类,并继承Ha

  • ThinkPHP中create()方法自动验证实例

    ThinkPHP中create()方法自动验证实例

    自动验证是ThinkPHP模型层提供的一种数据验证方法,可以在使用create创建数据对象的时候自动进行数据验证. 原理: create()方法收集表单($_POST)信息并返回,同时触发表单自动验证,过滤非法字段, 在控制器中使用create()方法,(返回值为true/false),会自动触发模型类中的$_validate属性(为父类Model中的方法,在子类Model中重写),在$_validate中自定义验证规则(验证规则下面会详细说明),当create()方法没有数据即返回值为fals

随机推荐