Таймер Erlang: sleep (1000) приводит к смерти в потоке - PullRequest
Новая
       18

Таймер Erlang: sleep (1000) приводит к смерти в потоке

1 голос
/ 13 июня 2019

Я пишу код на Erlang и использую timer.sleep (), но это нормально и код работает, когда я пишу timer.sleep (100), но мне нужно больше времени, чтобы остановить поток и когда я увеличиваю время и запустите timer.sleep (100) в функции, которая вызывается с порождением, тогда код не работает.

В коде второй io не печатается в консоли, поэтому поток замер в очереди: sleep (1000). 

request_handler ( Name, Amount, Banks ) ->
  io:format("~p ~p ~p ~n", [Name, Amount, Banks]),
  timer:sleep(1000),
  io:format("~p ~p ~p ~n", [Name, Amount, Banks]),
  if Amount < 50 ->
    Ask_amount = rand:uniform(Amount);
  true ->
    Ask_amount = rand:uniform(50)
    end,
  Bank = lists:nth(rand:uniform(length(Banks)), Banks),
  Pid = whereis(Bank),
  Pid ! {self(), Ask_amount},
  receive
    {accept, Ask_amount} ->
      request_handler(Name, (Amount - Ask_amount), Banks);
    {reject} ->
      request_handler(Name, Amount, lists:filter(fun (Elem) -> not lists:member(Elem, [Bank]) end, Banks ))
  end.

Любое тело знает, как я могу спать нить в эрланге в течение 1000 мс?

1 Ответ

0 голосов
/ 13 июня 2019

В коде второй io не печатается в консоли, поэтому поток мертвый в строке time: sleep (1000).

Во-первых, в erlang мы называем их процессов - не темы.Если процесс, работающий handle_request(), умирает во время сна, то есть до того, как второй оператор формата покажет какие-либо выходные данные, вы должны где-то увидеть сообщение об ошибке.

Вы не предоставили достаточно информации, чтобы помочь вам,По сути, ваш вопрос таков:

У меня в процессе работает следующая функция: 

go() ->
    io:format("hello"),
    timer:sleep(1000),
    io:format("goodbye").

Я не вижу второй вывод.Почему мой процесс умирает во время сна?

Ответ таков: потому что что-то убило ваш процесс.

Вот пример, который показывает, как вы можете заставить ваш request_handler() процесс спать для1 секунда:

handlers.erl: 

-module(handlers).
-compile([export_all]).

request_handler ( Name, Amount, Banks ) ->
    io:format("Format1: ~p ~p ~p ~n", [Name, Amount, Banks]),
    timer:sleep(1000),
    io:format("Format2: ~p ~p ~p ~n", [Name, Amount, Banks]),

    % This is how you write an if statement when you want to assign
    % the result to a variable:
    AskAmount = if 
                    Amount < 50 -> rand:uniform(Amount);
                    true        -> rand:uniform(50)
                end,
    Bank = lists:nth(rand:uniform(length(Banks)), Banks),
    Pid = whereis(Bank),
    Pid ! {self(), AskAmount},

    receive
        {accept, AskAmount} ->
            request_handler(Name, (Amount - AskAmount), Banks);
        {reject} ->
            request_handler(
                Name, 
                Amount, 
                lists:filter(fun (Elem) -> not lists:member(Elem, [Bank]) end, 
                             Banks 
                )
             )
    end.

Способ написания вышеприведенного оператора избавит от предупреждения:

Предупреждение: переменная 'Ask_amount 'экспортируется из', если

bank.erl: 

-module(bank).
-compile(export_all).

init(Name) ->
    register(Name, spawn(?MODULE, loop, [ok])).

loop(State) ->
    receive
        {From, Amount} ->
            From ! {accept, Amount},
            loop(State)
    end.

create_banks(Names) ->
    lists:foreach(
        fun(Name) -> init(Name) end,
        Names  %=> [bank1, bank2, bank3]
    ).

my.erl: 

-module(my).
-compile([export_all]).

go() ->
    BankNames = [bank1, bank2, bank3],
    bank:create_banks(BankNames),
    handlers:request_handler("Hello", 500, BankNames).

В оболочке: 

~/erlang_programs$ erl
Erlang/OTP 20 [erts-9.3] [source] [64-bit] [smp:4:4] [ds:4:4:10] [async-threads:10] [hipe] [kernel-poll:false]
Eshell V9.3  (abort with ^G)

1> c(bank).    
bank.erl:2: Warning: export_all flag enabled - all functions will be exported
{ok,bank}

2> c(handlers).
handlers.erl:2: Warning: export_all flag enabled - all functions will be exported
{ok,handlers}

3> c(my).      
my.erl:2: Warning: export_all flag enabled - all functions will be exported
{ok,my}

4> my:go().    
Format1: "Hello" 500 [bank1,bank2,bank3] 
Format2: "Hello" 500 [bank1,bank2,bank3] 
Format1: "Hello" 499 [bank1,bank2,bank3] 
Format2: "Hello" 499 [bank1,bank2,bank3] 
Format1: "Hello" 488 [bank1,bank2,bank3] 
Format2: "Hello" 488 [bank1,bank2,bank3] 
Format1: "Hello" 468 [bank1,bank2,bank3] 
Format2: "Hello" 468 [bank1,bank2,bank3] 
Format1: "Hello" 460 [bank1,bank2,bank3] 
Format2: "Hello" 460 [bank1,bank2,bank3] 
Format1: "Hello" 456 [bank1,bank2,bank3] 
Format2: "Hello" 456 [bank1,bank2,bank3] 
Format1: "Hello" 419 [bank1,bank2,bank3] 
...
...
^C^C

Ответ на комментарий :

Я хочу запускать функцию 'request_handler' более одного раза одновременно.... но когда я запускаю обработчик запросов: 

spawn(handlers, request_handler, [hello, 450, Banks])

второй IO не работает.

У меня работает: 

-module(my).
-compile([export_all]).

go() ->
    BankNames = [bank1, bank2, bank3],
    bank:create_banks(BankNames),
    lists:foreach(
        fun(N) -> 
            spawn(handlers, request_handler, [N, 500, BankNames])
        end,
        lists:seq(1, 5) %=> [1, 2, 3, 4, 5]
     ).

Вshell: 

~/erlang_programs$ erl
Erlang/OTP 20 [erts-9.3] [source] [64-bit] [smp:4:4] [ds:4:4:10] [async-threads:10] [hipe] [kernel-poll:false]
Eshell V9.3  (abort with ^G)

1> c(bank).    
bank.erl:2: Warning: export_all flag enabled - all functions will be exported
{ok,bank}

2> c(handlers).
handlers.erl:2: Warning: export_all flag enabled - all functions will be exported
{ok,handlers}

3> c(my).      
my.erl:2: Warning: export_all flag enabled - all functions will be exported
{ok,my}

4> my:go().    
process(<0.84.0>): Format1: 1 500 [bank1,bank2,bank3] 
process(<0.85.0>): Format1: 2 500 [bank1,bank2,bank3] 
process(<0.86.0>): Format1: 3 500 [bank1,bank2,bank3] 
process(<0.87.0>): Format1: 4 500 [bank1,bank2,bank3] 
process(<0.88.0>): Format1: 5 500 [bank1,bank2,bank3] 
ok
process(<0.84.0>): Format2: 1 500 [bank1,bank2,bank3] 
process(<0.85.0>): Format2: 2 500 [bank1,bank2,bank3] 
process(<0.86.0>): Format2: 3 500 [bank1,bank2,bank3] 
process(<0.87.0>): Format2: 4 500 [bank1,bank2,bank3] 
process(<0.88.0>): Format2: 5 500 [bank1,bank2,bank3] 
process(<0.84.0>): Format1: 1 467 [bank1,bank2,bank3] 
process(<0.87.0>): Format1: 4 471 [bank1,bank2,bank3] 
process(<0.85.0>): Format1: 2 465 [bank1,bank2,bank3] 
process(<0.86.0>): Format1: 3 460 [bank1,bank2,bank3] 
process(<0.88.0>): Format1: 5 453 [bank1,bank2,bank3] 
process(<0.84.0>): Format2: 1 467 [bank1,bank2,bank3] 
process(<0.87.0>): Format2: 4 471 [bank1,bank2,bank3] 
process(<0.85.0>): Format2: 2 465 [bank1,bank2,bank3] 
process(<0.86.0>): Format2: 3 460 [bank1,bank2,bank3] 
process(<0.88.0>): Format2: 5 453 [bank1,bank2,bank3] 
process(<0.84.0>): Format1: 1 422 [bank1,bank2,bank3] 
process(<0.86.0>): Format1: 3 441 [bank1,bank2,bank3] 
process(<0.87.0>): Format1: 4 461 [bank1,bank2,bank3] 
process(<0.88.0>): Format1: 5 413 [bank1,bank2,bank3] 
process(<0.85.0>): Format1: 2 442 [bank1,bank2,bank3] 
process(<0.84.0>): Format2: 1 422 [bank1,bank2,bank3] 
process(<0.86.0>): Format2: 3 441 [bank1,bank2,bank3] 
process(<0.87.0>): Format2: 4 461 [bank1,bank2,bank3] 
process(<0.88.0>): Format2: 5 413 [bank1,bank2,bank3] 
process(<0.85.0>): Format2: 2 442 [bank1,bank2,bank3] 
process(<0.84.0>): Format1: 1 405 [bank1,bank2,bank3] 
process(<0.86.0>): Format1: 3 416 [bank1,bank2,bank3] 
process(<0.87.0>): Format1: 4 439 [bank1,bank2,bank3] 
process(<0.88.0>): Format1: 5 376 [bank1,bank2,bank3] 
process(<0.85.0>): Format1: 2 419 [bank1,bank2,bank3] 
process(<0.84.0>): Format2: 1 405 [bank1,bank2,bank3] 
process(<0.86.0>): Format2: 3 416 [bank1,bank2,bank3] 
process(<0.87.0>): Format2: 4 439 [bank1,bank2,bank3] 
process(<0.88.0>): Format2: 5 376 [bank1,bank2,bank3] 
process(<0.85.0>): Format2: 2 419 [bank1,bank2,bank3] 
process(<0.84.0>): Format1: 1 397 [bank1,bank2,bank3] 
process(<0.86.0>): Format1: 3 394 [bank1,bank2,bank3] 
process(<0.85.0>): Format1: 2 389 [bank1,bank2,bank3] 
process(<0.87.0>): Format1: 4 401 [bank1,bank2,bank3] 
process(<0.88.0>): Format1: 5 340 [bank1,bank2,bank3] 
process(<0.84.0>): Format2: 1 397 [bank1,bank2,bank3] 
process(<0.86.0>): Format2: 3 394 [bank1,bank2,bank3] 
process(<0.85.0>): Format2: 2 389 [bank1,bank2,bank3] 
process(<0.87.0>): Format2: 4 401 [bank1,bank2,bank3] 
process(<0.88.0>): Format2: 5 340 [bank1,bank2,bank3] 
process(<0.84.0>): Format1: 1 367 [bank1,bank2,bank3] 
process(<0.87.0>): Format1: 4 400 [bank1,bank2,bank3] 
process(<0.86.0>): Format1: 3 355 [bank1,bank2,bank3] 
process(<0.85.0>): Format1: 2 370 [bank1,bank2,bank3] 
process(<0.88.0>): Format1: 5 313 [bank1,bank2,bank3] 
process(<0.84.0>): Format2: 1 367 [bank1,bank2,bank3] 
process(<0.87.0>): Format2: 4 400 [bank1,bank2,bank3] 
process(<0.86.0>): Format2: 3 355 [bank1,bank2,bank3] 
process(<0.85.0>): Format2: 2 370 [bank1,bank2,bank3] 
process(<0.88.0>): Format2: 5 313 [bank1,bank2,bank3] 
process(<0.84.0>): Format1: 1 337 [bank1,bank2,bank3] 
process(<0.87.0>): Format1: 4 381 [bank1,bank2,bank3] 
process(<0.88.0>): Format1: 5 299 [bank1,bank2,bank3] 
process(<0.86.0>): Format1: 3 329 [bank1,bank2,bank3] 
process(<0.85.0>): Format1: 2 367 [bank1,bank2,bank3] 

^C^C

Как видите, оба оператора io:format() отображают свои выходные данные.ok - это возвращаемое значение my:go(), которое возвращает то, что lists:foreach() возвращает, то есть ok.

...