2

Есть некий процесс который я хотел бы распараллелить, нагуглил пример с использованием AnyEvent. По факту через асинхронный таймер:

use strict;
use warnings;
use AnyEvent; 
use 5.016;
use Benchmark; # Для замера выполнения кода 

my $cv = AE::cv;
my @array = 1..10;

my $start_time = Benchmark->new;

sub worker {
    my $cb = shift;

    my $w;$w = AE::timer rand(0.1),0,sub {
        undef $w;
        $cb->();
    };
}

$cv->begin;
for my $cur (@array) {
    $cv->begin;

    worker sub {
        say "Начало процесса $cur";
        foreach(0...1000000) {
        }

        say "Конец процесса $cur";
        $cv->end;
    };

  #foreach(0...1000000) {


  # }
}

$cv->end;
$cv->recv;


my $end_time = Benchmark->new;
my $delta = timediff($end_time, $start_time);
say "\n\nВремя выполнение скрипта:\n" . timestr($delta);

сначала вместо цикла foreach(0...1000000) был sleep, посмотрел по времени выполнения с "асинхронностью" и линейно, время было одинаково (нууу... подумал я, может это слип так работает, он засыпает всю программу, это же все таки псевдо параллельность), добавил цикл, результат так же по времени одинаков. Вопрос, где тут параллельность, зачем заниматься самообманом? Я так понимаю, перл работает по такому принципу: введите сюда описание изображения по сути как корутина, т.е. общее время выполнение как не крути будет такое же как если бы код выполнялся линейно? Кстати через fork тоже время выполнения равно последовательному выполнению

2
  • твой пример абсолютно ... синтетический. попробуй что-то вроде параллельной загрузки страничек pragmaticperl.com/issues/21/… 4 окт 2018 в 9:28
  • Это пример асинхронного выполнения кода, асинхронное != параллельное. и причем тут загрузка странички, если мне нужно действие в программе распараллелить, по сути нужно некие действия выполнять параллельно для сокращения времени выполнения.
    – Артем
    4 окт 2018 в 9:45

1 ответ 1

3

Если хочется параллельности для использования CPU (а цикл - это именно потребление CPU), то нужны раздельные процессы. (Или треды, но использовать треды я бы категорически не рекомендовал). sleep усыпляет процесс, а т.к. процесс у нас один, то и усыпает он весь.

AnyEvent не для этого (равно как и Coro). Они для создания параллельности исполнения, когда основная часть работы процесса - это ожидание ввода-вывода (в основном по сети), а это подавляющее большинство задач в современных web-системах

6
  • кстати через fork тоже время выполнения равно последовательному выполнению
    – Артем
    4 окт 2018 в 12:25
  • А если мы распараллеливаем порождая несколько процессов через fork, если у нас отдельный процесс, это не будет то самое параллельное выполнение? (Кстати, в винде fork не создает доч. процесс, пид какой-то минусовой)
    – Артем
    4 окт 2018 в 14:44
  • "через fork" - хотелось бы тогда увидеть решение. Про винду сходу не скажу, но AFAIR fork в perl должен работать. Если несколько процессов, то да - это параллельное исполнение. 4 окт 2018 в 23:30
  • Кстати, для AnyEvent есть AnyEvent::Worker - он создаёт отдельный процесс и обрабатывает задачи в нём, синхронизируясь с основным процессом через асинхроннй сокет 4 окт 2018 в 23:31
  • 1
    Sorry, что влезаю. Сам Mons! Был впечатлён рассказом про aefor :) ну и всё что вокруг, на YAPC::Russia 2017, спасибо.
    – PinkTux
    5 окт 2018 в 22:38

Ваш ответ

By clicking “Отправить ответ”, you agree to our terms of service and acknowledge you have read our privacy policy.

Всё ещё ищете ответ? Посмотрите другие вопросы с метками или задайте свой вопрос.