Модераторы: ginnie, korob2001
  

Поиск:

Ответ в темуСоздание новой темы Создание опроса
> timeout в thread 
:(
    Опции темы
alezzz
Дата 10.7.2012, 10:22 (ссылка) | (нет голосов) Загрузка ... Загрузка ... Быстрая цитата Цитата


сплю...
**


Профиль
Группа: Участник
Сообщений: 499
Регистрация: 17.8.2009

Репутация: нет
Всего: 14



Нужно создать несколько потоков, каждый из которых будет слушать мультикаст и перенаправлять полученное по другому адресу. Сделал на threads и использовал IO::Socket::Multicast, в котором должен быть метод таймаут как наследие, но он не работает. Приходится лепить что отдельно от IO::Socket::Multicast чтобы поймать таймаут при долгом recv. В perldoc threads нашел такое:
Код

# Create thread with a task that may time out
  my $thr->create(sub {
      threads->yield();
      eval {
          $SIG{ALRM} = sub { die("Timeout\n"); };
          alarm(10);
          ...  # Do work here
          alarm(0);
      };
      if ($@ =~ /Timeout/) {
          warn("Task in thread timed out\n");
      }
  };

  # Set signal handler to relay SIGALRM to thread
  $SIG{ALRM} = sub { $thr->kill('ALRM') };

  ... # Main thread continues working

$SIG{ALRM} переопределяется в главном потоке, но для одного конкретного thread, а если потоков несколько, как для каждого переопределить сигнал?

Или приму в дар более простое решение на чем-то типа Coro или AnyEvent, пока не смог осилить создание нескольких потоков и контролирование их по таймауту в этих пакетах.
PM MAIL   Вверх
Pfailed
Дата 10.7.2012, 11:42 (ссылка) | (нет голосов) Загрузка ... Загрузка ... Быстрая цитата Цитата


Опытный
**


Профиль
Группа: Участник
Сообщений: 933
Регистрация: 19.7.2009

Репутация: 2
Всего: 39



Как обычно советую использовать неблокирующий ввод/вывод.
Вот какой-то пример с IO::Socket::Multicast и IO::Select: http://stackoverflow.com/questions/2732195...onger-connected
Ну и исходник свой выкладывайте если не получится.



--------------------
PM MAIL   Вверх
alezzz
Дата 10.7.2012, 12:36 (ссылка) | (нет голосов) Загрузка ... Загрузка ... Быстрая цитата Цитата


сплю...
**


Профиль
Группа: Участник
Сообщений: 499
Регистрация: 17.8.2009

Репутация: нет
Всего: 14



Pfailed, большое спасибо, смотрел на неблокируемый ввод/вывод, но пытаясь быстро найти решение не остановился на этом способе и уперся в таймауты. Как однопоточное решение работает, сейчас буду прикручивать к многопоточности.
PM MAIL   Вверх
  
Ответ в темуСоздание новой темы Создание опроса
Правила форума "Perl: Системное программирование"
korob2001
sharq
  • В этом разделе обсуждаются вопросы относящиеся только к системному программированию на Perl
  • Если ваш вопрос не относится к системному или CGI программированию, задавайте его в общем разделе
  • Если ваш вопрос относится к CGI программированию, задавайте его здесь
  • Интерпретатор Perl можно скачать здесь ActiveState, O'REILLY, The source for Perl
  • Справочное руководство "Установка perl-модулей", можно скачать здесь


Если Вам понравилась атмосфера форума, заходите к нам чаще! С уважением, korob2001, sharq.

 
1 Пользователей читают эту тему (1 Гостей и 0 Скрытых Пользователей)
0 Пользователей:
« Предыдущая тема | Perl: Системное программирование | Следующая тема »


 




[ Время генерации скрипта: 0.1009 ]   [ Использовано запросов: 21 ]   [ GZIP включён ]


Реклама на сайте     Информационное спонсорство

 
По вопросам размещения рекламы пишите на vladimir(sobaka)vingrad.ru
Отказ от ответственности     Powered by Invision Power Board(R) 1.3 © 2003  IPS, Inc.