快捷導(dǎo)航

Erlang中的并發(fā)程序簡(jiǎn)介

更新時(shí)間：2015年03月09日 09:16:34 投稿：junjie

這篇文章主要介紹了Erlang中的并發(fā)程序簡(jiǎn)介,本文講解了Erlang中基本的并發(fā)函數(shù)、并發(fā)程序模板、程序在出錯(cuò)時(shí)立即崩潰的優(yōu)點(diǎn)、為了在互聯(lián)網(wǎng)上執(zhí)行并發(fā)程序等內(nèi)容,需要的朋友可以參考下

Erlang中基本的并發(fā)函數(shù)

1） Pid =spwan(Mod,Func,Args) 創(chuàng)建一個(gè)新的進(jìn)程來(lái)執(zhí)行apply（Mod,Func,Args）,與調(diào)用進(jìn)程并列運(yùn)行，會(huì)使用最新的代碼定義模塊。
2） Pid！Message 向Pid進(jìn)程異步發(fā)送Message，！為發(fā)送操作符
3） Receive … end 接收消息

復(fù)制代碼代碼如下:

 receive

           Pattern1[when Guard1]-> Expression1;

           Pattern2[whenGuard2]->Expression2;

…

         aftertime->

                   Expressions

         end.

內(nèi)置函數(shù)erlang:system_info(process_limit)可找出所允許的最大進(jìn)程數(shù)，默認(rèn)為262144.
進(jìn)程注冊(cè)的內(nèi)置函數(shù)有：
register（AnAtom，Pid）用名稱注冊(cè)Pid
uregister（AnAtom）注銷關(guān)聯(lián)注冊(cè)
whereis(AnAtom)->Pid|undefined 檢查Pid是否注冊(cè)
registered()->[AnAtom::atom()]返回系統(tǒng)里所有注冊(cè)進(jìn)程的列表。

并發(fā)程序模板：

復(fù)制代碼代碼如下:

-module(ctemplate).

-compile(export_all).

start() ->

         Spwan(?MODULE,loop,[]).

rpc(Pid,Request) ->

         Pid! {self(),Request},

         receive

                   {Pid,Respone}->

                            Response

         end.

loop(X) ->

         receive

                   Any->

                            Io:format(“Received:~p ~n”, [Any]),

                            loop(X)

         end.

每當(dāng)收到消息時(shí)會(huì)處理它并再次調(diào)用loop(),這一過程稱為尾遞歸，無(wú)需消耗堆?？臻g可以一直循環(huán)下去。

Erlang并發(fā)程序的錯(cuò)誤處理建立在遠(yuǎn)程監(jiān)測(cè)和處理錯(cuò)誤的基礎(chǔ)上，重點(diǎn)在補(bǔ)救而不是預(yù)防，幾乎沒有防御性代碼，只有在錯(cuò)誤后清理系統(tǒng)的代碼，即讓其他進(jìn)程修復(fù)錯(cuò)誤和任其崩潰。

程序在出錯(cuò)時(shí)立即崩潰的優(yōu)點(diǎn)：
1）不編寫防御性代碼，直接崩潰簡(jiǎn)單
2）別人來(lái)修復(fù)
3）不會(huì)使錯(cuò)誤惡化
4）第一時(shí)間舉旗示意
5）修復(fù)時(shí)不擔(dān)心原因重在清理
6）簡(jiǎn)化了系統(tǒng)架構(gòu)
監(jiān)視和連接類似，但監(jiān)視是單向的，如果被監(jiān)視的進(jìn)程掛了會(huì)向監(jiān)視進(jìn)程發(fā)一“宕機(jī)“消息，而不是退出信號(hào)?；惧e(cuò)誤處理函數(shù)有：

復(fù)制代碼代碼如下:

-spec spwan_link(Fun) ->Pid

-spec spwan_monitor(Fun)-> {Pid,Ref}

-spec process_flag(trap_exit,true)

-spec link(Pid) ->true

-spec unlink(Pid) -> true

-spec erlang:monitor(process,Item) ->Ref

-spec exit(Why) -> none()

分布式模型：分布式erlang 和基于socket的分布式模型。分布式erlang運(yùn)行在可信網(wǎng)絡(luò)，通常在同一局域網(wǎng)的集群上，并受防火墻保護(hù)?；趕ocket的分布式模型基于TCP/IP不可信網(wǎng)絡(luò).
分布式Erlang的主要問題在于客戶端可以自行決定在服務(wù)器上分裂出多種進(jìn)程，適合于你擁有全部的機(jī)器，并且想在單臺(tái)機(jī)器上控制他們。lib_chan 模塊讓用戶能夠顯式控制自己的機(jī)器分裂出哪些進(jìn)程。

為了在互聯(lián)網(wǎng)上執(zhí)行并發(fā)程序：

1）確保4369端口對(duì)TCP和UDP都開發(fā)，該端口保留給epmd（Erlang端口映射守護(hù)進(jìn)程）
2）選擇1個(gè)或一段連續(xù)的端口給分布式erlang使用，確保這些端口開放，例如：

復(fù)制代碼代碼如下:

$erl  -name …-setcookie …  -kernelinet_dist_listen_min Min \

           Inet_dist_listen_maxMax

Rpc提供了許多遠(yuǎn)程調(diào)用服務(wù)，global里的函數(shù)可以用來(lái)在分布式系統(tǒng)里注冊(cè)名稱以及維護(hù)一個(gè)全連接的網(wǎng)絡(luò)。

Erlang集群就是一組帶有相同cookie的互連節(jié)點(diǎn)。創(chuàng)建cookie的三種方法：
1）在文件$HOME/.erlang.cookie存放相同的cookie
2）在Erlang啟動(dòng)時(shí)，可以用 –setcookie，例如

復(fù)制代碼代碼如下:

$erl -setcookieABCDEFG2048

3）內(nèi)置函數(shù)erlang:set_cookie(node(),C)在程序中指定

Erlang通過名為端口的對(duì)象與外部程序通信，如果想端口發(fā)送一個(gè)消息，這一消息就會(huì)被發(fā)往與端口相連的外部程序，來(lái)自外部程序的消息會(huì)變成來(lái)自端口的Erlang消息。創(chuàng)建端口的進(jìn)程成為端口的相連進(jìn)程，所有發(fā)往端口的消息都必須標(biāo)明相連進(jìn)程的PID，所有來(lái)自外部程序的消息都會(huì)發(fā)往相連進(jìn)程。