acm queue 9月的雜志的主題是The Concurrency Problem,力推了Erlang這個(gè)語(yǔ)言,其中有篇文章簡(jiǎn)單的介紹了下這個(gè)message-oriented語(yǔ)言。
查了下這個(gè)名字的讀法,正確的讀法應(yīng)該是air-lang,這里元音a的發(fā)音和bang中的a一樣。
文章中的第一個(gè)程序就有點(diǎn)令人費(fèi)解,主要原因在于Erlang的語(yǔ)法和一般的imperative language差別很大,和functional language比較類(lèi)似,但是本質(zhì)上也有很大的不同。
以Java的一個(gè)計(jì)數(shù)程序?yàn)槔?br />
//?A?shared?counter.
public?class?Sequence?{
????private?int?nextVal?=?0;
?
????//?Retrieve?counter?and?increment.
????public?synchronized?int?getNext()?{
????????return?nextVal++;
????}
?
????//?Re-initialize?counter?to?zero.
????public?synchronized?void?reset()?{
????????nextVal?=?0;
????}
}
這個(gè)程序的功能不用多說(shuō)了,一個(gè)同步的計(jì)數(shù)程序。它的Erlang翻譯版的代碼為
-module(sequence1).
-export([make_sequence/0, get_next/1, reset/1]).
?
% Create a new shared counter.
make_sequence() ->
spawn(fun() -> sequence_loop(0)end).
?
sequence_loop(N) ->
receive
{From, get_next} ->
From!{self(), N},
sequence_loop(N + 1)<SEMI>
reset ->
sequence_loop(0)
end.
?
% Retrieve counter and increment.
get_next(Sequence) ->
Sequence!{self(), get_next},
receive
{Sequence, N} -> N
end.
?
% Re-initialize counter to zero.
reset(Sequence) ->
Sequence! reset.
初看這個(gè)程序自然是一頭霧水,不過(guò)程序的函數(shù)式風(fēng)格味還是很濃的。
前面提到,Erlang是基于message的,或者說(shuō)message sending機(jī)制是包含在語(yǔ)言系統(tǒng)內(nèi)部的,語(yǔ)法就是 pid ! message
接下來(lái)再來(lái)分析這個(gè)簡(jiǎn)單的程序。開(kāi)頭兩行是模塊和函數(shù)聲明,略去。make_sequence開(kāi)始這個(gè)進(jìn)程,spawn/1內(nèi)置函數(shù)創(chuàng)建一個(gè)新的進(jìn)程,并返回pid到調(diào)用者。
初始時(shí)運(yùn)行的函數(shù)是sequence_loop(0),這個(gè)函數(shù)接收兩種信息,用receive表達(dá)式聲明:如果收到形式是{From,
get_next}的信息,就返回當(dāng)前的N并調(diào)用sequence_loop(N+1),這樣下一次收到同樣的信息時(shí)就能返回N+1了;reset則等價(jià)
于Java版本中的n=0語(yǔ)句。
get_next/1則是發(fā)送給pid為Sequence的進(jìn)程 {self(), get_next}
這樣一個(gè)信息,上面解釋的sequence_loop/1函數(shù)收到這個(gè)信息后會(huì)返回一個(gè) {self(), N}
的tuple給get_next/1,收到這個(gè)信息后get_next/1就能返回N這個(gè)值了。
最后reset/1函數(shù)則是發(fā)送給Sequence一個(gè)reset信息。
這個(gè)簡(jiǎn)單的程序里能大致窺見(jiàn)一些Erlang的特點(diǎn),尤其是它基于信息發(fā)送的本質(zhì)。