Подсчитать количество положительных элементов в очереди

%%% функция преобразования(потребления) элемента
%% Найти количество положительных элементов
num_poz([],_) -> 0;
num_poz([H|T],N) when H > 0 -> N1 = unbound, num_poz(T, N1), N=N1+1.
num_poz([H|T],N) when H=<0 -> num_poz(T, N).
 
consume(X)->{num_poz(X)}.

-module(lr6).
-compile(nowarn_export_all).
-compile(export_all).
 
%%% процесс организующий общий буфер
%% Очередь
bufer(Buf)->
  io:format("Buffer      = ~w~n",[Buf]),
  receive
    {get,Pid} when (length(Buf)>0) -> [H|T]=Buf, Pid!{item,H}, bufer(T);
    {put,Value} -> bufer(Buf ++ [Value]);
    {clear} -> bufer([]);
    {stop} -> ok
  end.
 
%%% процесс производителя
producer(Number_proc,0)-> io:format("[Producer ~w] finished ~n",[Number_proc]);
producer(Number_proc,Count_iter)->
  random:seed(Number_proc,Count_iter,0),
  Elem=[Number_proc|produce(4)], % произведенный элемент
  io:format("[Producer ~w] create ~w~n",[Number_proc,Elem]),
  base!{put,Elem},
  producer(Number_proc,Count_iter-1).
 
%%% генерировать числовой список
produce(0)->[];
produce(X)->[5-random:uniform(10)|produce(X-1)].
 
%%% процесс потребителя
consumer(Number_proc,0)-> io:format("[Consumer ~w] finished ~n",[Number_proc]);
consumer(Number_proc,Count_iter)->
  base!{get,self()},
  receive
    {item,Elem} -> io:format("[Consumer ~w] consume ~w~n",[Number_proc,consume(Elem)]),
      consumer(Number_proc,Count_iter-1);
    {stop}->ok
  end.
 
%%% функция преобразования(потребления) элемента
%% Найти количество положительных элементов
num_poz([],_) -> 0;
num_poz([H|T],N) when H > 0 -> N1 = unbound, num_poz(T, N1), N=N1+1.
num_poz([H|T],N) when H=<0 -> num_poz(T, N).
 
consume(X)->{num_poz(X)}.
 
start() ->
  %% 1.создание процесса буфера
  case whereis(base) of
    undefined -> register(base,spawn(lr6, bufer,[[]]));
    _  -> base!{clear}
  end,
  io:format("Buffer initialized, all right!~n"),
  %% 2. создание процессов производителей
  [spawn(lr6,producer,[X,5]) || X <- [1,2,3,4,5]],
  %% 3. создание процессов потребителей
  [spawn(lr6,consumer,[X,5]) || X <- [1,2,3,4,5]],
  io:format("Init finished....~n~n").
 
stop() ->
  base!{stop}.

num_poz([],N) -> N;
num_poz([H|T],N) when H > 0 -> num_poz(T, N+1);
num_poz([_|T],N) -> num_poz(T, N).
 
num_poz(L) -> num_poz(L,0).

num_pos([]) -> 0;
num_pos([H|T]) -> if H > 0 -> 1+num_pos(T);
                     true  -> num_pos(T)
                  end.