From 84adefa331c4159d432d22840663c38f155cd4c1 Mon Sep 17 00:00:00 2001
From: Erlang/OTP <otp@erlang.org>
Date: Fri, 20 Nov 2009 14:54:40 +0000
Subject: The R13B03 release.

---
 lib/percept/doc/src/sorter.erl | 41 +++++++++++++++++++++++++++++++++++++++++
 1 file changed, 41 insertions(+)
 create mode 100644 lib/percept/doc/src/sorter.erl

(limited to 'lib/percept/doc/src/sorter.erl')

diff --git a/lib/percept/doc/src/sorter.erl b/lib/percept/doc/src/sorter.erl
new file mode 100644
index 0000000000..8d5f2c715c
--- /dev/null
+++ b/lib/percept/doc/src/sorter.erl
@@ -0,0 +1,41 @@
+-module(sorter).
+-export([go/3,loop/0,main/4]).
+
+go(I,N,M) ->
+    spawn(?MODULE, main, [I,N,M,self()]),
+    receive done -> ok end.
+
+main(I,N,M,Parent) ->
+    Pids = lists:foldl(
+	fun(_,Ps) -> 
+	    [ spawn(?MODULE,loop, []) | Ps]
+	end, [], lists:seq(1,M)),
+
+    lists:foreach(
+	fun(_) -> 
+	    send_work(N,Pids),
+	    gather(Pids)
+	end, lists:seq(1,I)),
+
+    lists:foreach(
+	fun(Pid) ->
+	    Pid ! {self(), quit}
+	end, Pids),
+
+    gather(Pids), Parent ! done.
+
+send_work(_,[]) -> ok;
+send_work(N,[Pid|Pids]) ->
+    Pid ! {self(),sort,N},
+    send_work(round(N*1.2),Pids).
+
+loop() ->
+    receive
+	{Pid, sort, N} -> dummy_sort(N),Pid ! {self(), done},loop();
+	{Pid, quit} -> Pid ! {self(), done}
+    end.
+	    
+dummy_sort(N) -> lists:sort([ random:uniform(N) || _ <- lists:seq(1,N)]).
+
+gather([]) -> ok;
+gather([Pid|Pids]) -> receive {Pid, done} -> gather(Pids) end.
-- 
cgit v1.2.3