青青草原综合久久大伊人导航_色综合久久天天综合_日日噜噜夜夜狠狠久久丁香五月_热久久这里只有精品

教父的告白
一切都是紙老虎
posts - 82,  comments - 7,  trackbacks - 0
    Erlang中的process——進程是輕量級的,并且進程間無共享。查了很多資料,似乎沒人說清楚輕量級進程算是什么概念,繼續查找中。。。閑話不 提,進入并發編程的世界。本文算是學習筆記,也可以說是《Concurrent Programming in ERLANG》第五張的簡略翻譯。
1.進程的創建
    進程是一種自包含的、分隔的計算單元,并與其他進程并發運行在系統中,在進程間并沒有一個繼承體系,當然,應用開發者可以設計這樣一個繼承體系。
    進程的創建使用如下語法:
java 代碼
  1. Pid = spawn(Module, FunctionName, ArgumentList)  

spawn接受三個參數:模塊名,函數名以及參數列表,并返回一個代表創建的進程的標識符(Pid)。
如果在一個已知進程Pid1中執行:
java 代碼
  1. Pid2 = spawn(Mod, Func, Args)  

那么,Pid2僅僅能被Pid1可見,Erlang系統的安全性就構建在限制進程擴展的基礎上。

2.進程間通信
    Erlang進程間的通信只能通過發送消息來實現,消息的發送使用!符號:
java 代碼
  1. Pid ! Message  

    其中Pid是接受消息的進程標記符,Message就是消息。接受方和消息可以是任何的有效的Erlang結構,只要他們的結果返回的是進程標記符和消息。
    消息的接受是使用receive關鍵字,語法如下:
java 代碼
  1. receive  
  2.       Message1 [when Guard1] ->  
  3.           Actions1 ;  
  4.       Message2 [when Guard2] ->  
  5.           Actions2 ;  
  6.   
  7. end  

    每一個Erlang進程都有一個“郵箱”,所有發送到進程的消息都按照到達的順序存儲在“郵箱”里,上面所示的消息Message1,Message2, 當它們與“郵箱”里的消息匹配,并且約束(Guard)通過,那么相應的ActionN將執行,并且receive返回的是ActionN的最后一條執行 語句的結果。Erlang對“郵箱”里的消息匹配是有選擇性的,只有匹配的消息將被觸發相應的Action,而沒有匹配的消息將仍然保留在“郵箱”里。這 一機制保證了沒有消息會阻塞其他消息的到達。
    消息到達的順序并不決定消息的優先級,進程將輪流檢查“郵箱”里的消息進行嘗試匹配。消息的優先級別下文再講。

    如何接受特定進程的消息呢?答案很簡單,將發送方(sender)也附送在消息當中,接收方通過模式匹配決定是否接受,比如:
java 代碼
  1. Pid ! {self(),abc}  

給進程Pid發送消息{self(),abc},利用self過程得到發送方作為消息發送。然后接收方:
java 代碼
  1. receive  
  2.   {Pid1,Msg} ->  
  3.   
  4. end  

通過模式匹配決定只有Pid1進程發送的消息才接受。

3.一些例子
    僅說明下書中計數的進程例子,我添加了簡單注釋:
java 代碼
 
  1. -module(counter).  
  2. -compile(export_all).  
  3. % start(),返回一個新進程,進程執行函數loop  
  4. start()->spawn(counter, loop,[0]).  
  5. % 調用此操作遞增計數  
  6. increment(Counter)->  
  7.     Counter!increament.  
  8. % 返回當前計數值  
  9. value(Counter)->  
  10.     Counter!{self(),value},  
  11.     receive  
  12.         {Counter,Value}->  
  13.             %返回給調用方  
  14.             Value  
  15.         end.  
  16.   %停止計數        
  17.  stop(Counter)->  
  18.      Counter!{self(),stop}.  
  19.  loop(Val)->  
  20.      receive  
  21.          %接受不同的消息,決定返回結果  
  22.          increament->  
  23.              loop(Val+1);  
  24.          {From,value}->  
  25.              From!{self(),Val},  
  26.              loop(Val);  
  27.          stop->  
  28.              true;  
  29.          %不是以上3種消息,就繼續等待  
  30.          Other->  
  31.              loop(Val)  
  32.       end.     
  33.                
  34.                           
  35.           

調用方式:

java 代碼
 
  1. 1> Counter1=counter:start().  
  2. <0.30.0>  
  3. 2> counter:value(Counter1).  
  4. 0  
  5. 3> counter:increment(Counter1).  
  6. increament  
  7. 4> counter:value(Counter1).  
  8. 1  

基于進程的消息傳遞機制可以很容易地實現有限狀態機(FSM),狀態使用函數表示,而事件就是消息。具體不再展開

4.超時設置
    Erlang中的receive語法可以添加一個額外選項:timeout,類似:
java 代碼
  1. receive  
  2.    Message1 [when Guard1] ->  
  3.      Actions1 ;  
  4.    Message2 [when Guard2] ->  
  5.      Actions2 ;  
  6.      
  7.    after  
  8.       TimeOutExpr ->  
  9.          ActionsT  
  10. end  

after之后的TimeOutExpr表達式返回一個整數time(毫秒級別),時間的精確程度依賴于Erlang在操作系統或者硬件的實現。如果在time毫秒內,沒有一個消息被選中,超時設置將生效,也就是ActionT將執行。time有兩個特殊值:
1)infinity(無窮大),infinity是一個atom,指定了超時設置將永遠不會被執行。
2) 0,超時如果設定為0意味著超時設置將立刻執行,但是系統將首先嘗試當前“郵箱”里的消息。

    超時的常見幾個應用,比如掛起當前進程多少毫秒:
java 代碼
 
  1. sleep(Time) ->  
  2.   receive  
  3.     after Time ->  
  4.     true  
  5. end.  

    比如清空進程的“郵箱”,丟棄“郵箱”里的所有消息:
java 代碼
 
  1. flush_buffer() ->  
  2.   receive  
  3.     AnyMessage ->  
  4.       flush_buffer()  
  5.   after 0 ->  
  6.     true  
  7. end.  
   
    將當前進程永遠掛起:
java 代碼
 
  1. suspend() ->  
  2.     receive  
  3.     after  
  4.         infinity ->  
  5.             true  
  6.     end.  

       超時也可以應用于實現定時器,比如下面這個例子,創建一個進程,這個進程將在設定時間后向自己發送消息:
java 代碼
 
  1. -module(timer).  
  2. -export([timeout/2,cancel/1,timer/3]).  
  3. timeout(Time, Alarm) ->  
  4.    spawn(timer, timer, [self(),Time,Alarm]).  
  5. cancel(Timer) ->  
  6.    Timer ! {self(),cancel}.  
  7. timer(Pid, Time, Alarm) ->  
  8.    receive  
  9.     {Pid,cancel} ->  
  10.        true  
  11.    after Time ->  
  12.        Pid ! Alarm  
  13. end.  

   
5、注冊進程
    為了給進程發送消息,我們需要知道進程的Pid,但是在某些情況下:在一個很大系統里面有很多的全局servers,或者為了安全考慮需要隱藏進程 Pid。為了達到可以發送消息給一個不知道Pid的進程的目的,我們提供了注冊進程的辦法,給進程們注冊名字,這些名字必須是atom。
    基本的調用形式:
java 代碼
  1. register(Name, Pid)  
  2. 將Name與進程Pid聯系起來  
  3.   
  4. unregister(Name)  
  5. 取消Name與相應進程的對應關系。  
  6.   
  7. whereis(Name)  
  8. 返回Name所關聯的進程的Pid,如果沒有進程與之關聯,就返回atom:undefined  
  9.   
  10. registered()  
  11. 返回當前注冊的進程的名字列表  

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的模型,書中有一節專門討論了這一點,著重強調了接口的設計以及抽象層次的隔離問題,不翻譯了。
posted on 2009-09-11 10:12 暗夜教父 閱讀(319) 評論(0)  編輯 收藏 引用 所屬分類: erlang

<2009年9月>
303112345
6789101112
13141516171819
20212223242526
27282930123
45678910

常用鏈接

留言簿(2)

隨筆分類

隨筆檔案

文章分類

文章檔案

搜索

  •  

最新評論

閱讀排行榜

評論排行榜

青青草原综合久久大伊人导航_色综合久久天天综合_日日噜噜夜夜狠狠久久丁香五月_热久久这里只有精品
  • <ins id="pjuwb"></ins>
    <blockquote id="pjuwb"><pre id="pjuwb"></pre></blockquote>
    <noscript id="pjuwb"></noscript>
          <sup id="pjuwb"><pre id="pjuwb"></pre></sup>
            <dd id="pjuwb"></dd>
            <abbr id="pjuwb"></abbr>
            亚洲男人的天堂在线| 亚洲欧美国产精品桃花| 免费观看在线综合色| 亚洲一区欧美二区| 这里只有精品在线播放| 亚洲毛片在线免费观看| 亚洲久久在线| 一区二区三区免费在线观看| 亚洲午夜在线| 久久国产精品99国产精| 久久香蕉国产线看观看网| 欧美69视频| 国产精品久久激情| 国内激情久久| 91久久国产综合久久| 中日韩高清电影网| 久久国产综合精品| 欧美福利精品| 亚洲无线视频| 免费不卡在线观看av| 欧美视频在线免费看| 国内成+人亚洲+欧美+综合在线| 亚洲国产日韩一区二区| 亚洲在线一区二区| 欧美xxx在线观看| 亚洲最新在线视频| 久久免费视频这里只有精品| 欧美三级小说| 亚洲国产精品激情在线观看| 99在线精品观看| 国产精品视频免费一区| 1024日韩| 久久成人18免费网站| 亚洲精品日本| 久久综合色综合88| 国产日韩成人精品| 一本大道久久a久久精品综合| 久久久久久网| 在线亚洲欧美专区二区| 久久中文字幕一区| 国产精品美女一区二区| 亚洲精品1区2区| 久久久久久久一区| 在线视频一区二区| 欧美激情片在线观看| 揄拍成人国产精品视频| 亚洲欧美日韩一区二区| 亚洲人成人一区二区在线观看| 亚洲午夜av电影| 欧美精品一区二区三区很污很色的| 国产一区二区久久精品| 欧美呦呦网站| 亚洲一区二区三区四区视频| 欧美美女福利视频| 亚洲欧洲中文日韩久久av乱码| 久久综合色播五月| 久久超碰97中文字幕| 国产日韩欧美一区二区| 欧美一区二区视频在线| 亚洲视频碰碰| 国产精品蜜臀在线观看| 亚洲欧美日产图| 亚洲视频一区在线| 欧美日韩小视频| 亚洲在线播放电影| 亚洲午夜精品网| 国产精品入口麻豆原神| 欧美一二三区精品| 欧美一级免费视频| 国内视频一区| 欧美成人精品高清在线播放| 麻豆久久婷婷| 日韩写真视频在线观看| 亚洲免费精彩视频| 国产精品久久久久aaaa九色| 亚洲欧美色一区| 午夜精品视频在线观看一区二区 | 欧美一区亚洲| 欧美大片在线看免费观看| 久久影院午夜片一区| 在线观看亚洲精品| 欧美高清一区| 欧美精品色综合| 亚洲免费在线播放| 欧美一区二区大片| 永久免费视频成人| 欧美国产日韩一区二区| 欧美日韩网址| 久久一区二区三区av| 欧美电影专区| 亚洲欧美日本日韩| 久久综合色88| 亚洲欧美另类中文字幕| 久久久国产一区二区三区| 一本色道久久综合亚洲二区三区 | 久久久久免费| 欧美激情一区二区| 久久国产精品一区二区| 免费欧美在线视频| 午夜精品福利一区二区三区av | 久久久久国产免费免费| 欧美国内亚洲| 久久久7777| 欧美日韩一二三四五区| 开心色5月久久精品| 欧美视频在线一区二区三区| 欧美jizz19hd性欧美| 国产精品嫩草99a| 亚洲高清在线| 国内精品福利| 亚洲一区二区三区在线| 日韩视频在线观看| 噜噜噜91成人网| 久久精品亚洲乱码伦伦中文 | 亚洲电影自拍| 亚洲欧美不卡| 中文一区二区在线观看| 久久夜色精品国产欧美乱极品| 亚洲欧美不卡| 欧美日韩极品在线观看一区| 免费观看日韩| 狠狠色噜噜狠狠色综合久 | 一本色道久久88亚洲综合88| 一区二区三区在线免费观看| 国产精品99久久99久久久二8 | 久久人体大胆视频| 国产免费亚洲高清| 99热这里只有精品8| 亚洲色图在线视频| 久久九九国产精品怡红院| 欧美日韩高清在线| 欧美激情导航| 伊大人香蕉综合8在线视| 香蕉av777xxx色综合一区| 亚洲欧美资源在线| 国产精品久久77777| 夜夜躁日日躁狠狠久久88av| avtt综合网| 欧美日韩亚洲高清一区二区| 亚洲精品极品| 99天天综合性| 欧美视频一区二区三区四区| 99精品欧美一区| 亚洲欧美另类在线观看| 国产精品色午夜在线观看| 亚洲在线观看视频网站| 欧美在现视频| 狠狠色综合网| 老司机久久99久久精品播放免费| 久久午夜av| 亚洲日本无吗高清不卡| 欧美大片免费久久精品三p | 欧美在线观看天堂一区二区三区| 亚洲欧美日韩视频一区| 国产日韩av一区二区| 久久久久成人网| 女人色偷偷aa久久天堂| 亚洲精品国产品国语在线app| 欧美黄色一级视频| 一区二区三区回区在观看免费视频| 亚洲手机视频| 国产日韩在线亚洲字幕中文| 久久久综合香蕉尹人综合网| 亚洲国产高清自拍| 亚洲免费婷婷| 精品成人在线视频| 欧美日韩国产黄| 欧美一级片一区| 亚洲日本成人在线观看| 欧美在线高清| 亚洲乱码一区二区| 国产伦精品一区二区三区视频黑人| 久久久久九九视频| 夜夜夜久久久| 欧美激情麻豆| 久久精品99国产精品| 亚洲另类一区二区| 国产亚洲精品一区二区| 欧美国产欧美综合| 欧美一区二区三区免费视| 亚洲国产日韩综合一区| 欧美专区亚洲专区| 99精品久久久| 悠悠资源网久久精品| 国产精品日韩欧美一区二区| 蘑菇福利视频一区播放| 亚洲一区二区视频| 亚洲人成网站在线观看播放| 久久精品在线播放| 亚洲一区二区毛片| 最近中文字幕mv在线一区二区三区四区 | 午夜精品免费在线| 亚洲免费观看视频| 欧美激情日韩| 卡一卡二国产精品| 久久精品视频在线观看| 99爱精品视频| 麻豆精品视频在线观看视频| 国产精品99久久久久久白浆小说| 你懂的视频一区二区|