Эрланг и процессы - PullRequest
Новая
       19

Эрланг и процессы

1 голос
/ 06 декабря 2009

Я очень плохо знаком с Эрлангом и сейчас читаю книгу Джо Армстронга, главу «Параллельное программирование». Я пытаюсь запустить список процессов, чтобы вычислить, является ли число простым числом (наивный метод). Но мой код работает так, как будто не было никаких процессов. Оба метода имеют одинаковую продолжительность. Где я не прав?

shell.erl: 

c(prime).

%a list of primes
NUMS=[102950143,102950143,102950143,102950143,102950143].

%time start
NOW1=now().
io:fwrite("Monothread~n").

%for each number test if it is a prime
lists:foreach( fun(N)->
    RESULT=prime:is_prime(N),
    io:fwrite("Result N=~p ~n",[RESULT])
    end, NUMS).
%display the duration
io:fwrite("Duration N=~p ~n",[timer:now_diff(now(),NOW1)/1.0e6]).

%time start
NOW2=now().
io:fwrite("Multithread~n").
%for each number, spawn a new process and test if it is a prime
lists:foreach( fun(N)->ProcId = prime:start(),
    io:fwrite("Calculating : procId=~p N=~p ~n",[ProcId,N]),
    RESULT=prime:is_prime(ProcId,N),
    io:fwrite("Result N=~p ~n",[RESULT])
    end, NUMS).
%display the duration   
io:fwrite("Duration N=~p ~n",[timer:now_diff(now(),NOW2)/1.0e6]).

halt().

файл prime.erl: 

-module(prime).
-export([start/0,is_prime/1,is_prime/2]).
%run the forever_function
start()->spawn(fun forever_function/0).

%catch the queries
forever_function()->
    receive
        { From,Number} -> From! is_prime(self(),2,Number),
        forever_function()
    end.

%monothreaded function
is_prime(Number)->is_prime(self(),2,Number).

%multithreaded function
is_prime(ProcessID,Number)->
    ProcessID ! {self(),Number},
    receive
        RESULT->RESULT
    end.

%recursive function scanning all the numbers from 2 to Number
is_prime(ProcessID,Div,Number)->
    if
        Div =:= Number -> {{number,Number},{prime,true}};
        Number rem Div =:= 0 -> {{number,Number},{prime,false}};
        true-> is_prime(ProcessID,Div+1,Number)
    end.

Спасибо

Pierre

1 Ответ

12 голосов
/ 06 декабря 2009

В ваших списках: вызов foreach во втором блоке, вы звоните RESULT=prime:is_prime(ProcId,N), что делает receive для результата. Итак, вы порождаете процесс, а затем ждете его завершения, пока не создадите следующий процесс. Вот почему это занимает столько же времени, сколько и однопоточный подход: в обоих случаях вы выполняете только по одному за раз.

Вместо этого вам нужно сначала запустить все процессы (используя что-то вроде lists:map, чтобы отслеживать все PID), а затем ждать результатов на отдельном шаге. Обратите внимание, что это означает, что вам придется отделить часть ProcessID ! {self(),Number} от части receive, чтобы это можно было сделать на первом шаге, в противном случае вы просто создаете кучу бездействующих процессов.

Итак, что-то вроде: 

Pids = lists:map( fun(N)-> ProcId = prime:start(N),
    io:fwrite("Calculating : procId=~p N=~p ~n",[ProcId,N]),
    ProcId end, NUMS).
lists:foreach( fun(ProcId) -> {N,RESULT}=prime:is_prime(ProcId),
    io:fwrite("Result procId=~p N=~p Result=~p ~n", [ProcId,N,RESULT]) end, Pids).

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

forever_function(Number)->
    Result = is_prime(self(),2,Number),
    receive
        { From, get_result } -> From! {Number,Result},
        % unnecessary since we never call this Pid again, but do it anyway :)
        forever_function()
        % could also add more cases here to set the number
        % or even do a one-shot function like before
    end.

%multithreaded function
is_prime(ProcessID)->
    ProcessID ! {self(),get_result},
    receive
        RESULT->RESULT
    end.

Примечание: это не проверено, поэтому может потребоваться некоторая настройка.

...