VPF::Разветвляющие серверы - Форум программистов

GShadrin

Дата 1.12.2009, 17:15 (ссылка)

(нет голосов)

Загрузка ...

Шустрый

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

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

Здравствуйте.
Столкнулся с необходимостью написания сервера, в котором для каждого подключившегося пользователя выделяется отдельный процесс. Воспользовался рецептом из кукбук 17.11

Код


Ответвляйте подпроцессы в цикле accept и используйте обработчик $SIG{CHLD} для чистки потомков. 
# Создать сокет SERVER, вызвать bind и прослушивать ... 
use POSIX qw(: sys_wait_h); 
sub REAPER { 
1 until (-1 == waitpid(-1, wnohang)); 
$SIG{CHLD} = \&reaper; # если $l >= 5.002 
} 
$SIG{CHLD} = \&reaper; 
while ($hisaddr = accept(client, server)) { 
next if $pid = fork; # Родитель 
die "fork: $!" unless defined $pid; # Неудача 
# otherwise child 
close(SERVER); # He нужно для потомка 
# ... Сделать что-то 
exit; # Выход из потомка 
} continue { 
close(CLIENT); # He нужно для родителя 
}

Вопрос:
Мне необходимо иметь некоторые данные общие для всех потоков. Как это сделать? При попытки объявления глобальной переменной $i и увеличении ее при каждом подключении нового пользователя с печатью номера вновь подключившегося пользователя привело к печати всегда 1, т.е. для каждого потока $i свое. Похоже это связано с использованием fork. Как сделать общую?

Bulat

Дата 1.12.2009, 17:48 (ссылка)

(нет голосов)

Загрузка ...

татарский Нео

Профиль
Группа: Завсегдатай
Сообщений: 1701
Регистрация: 22.3.2006
Где: Альметьевск

Репутация: 5
Всего: 57

Цитата(GShadrin @ 1.12.2009, 17:15

)

next if $pid = fork; # Родитель

А зачем ты так жестко-то с родителем??

я так понял что тебе нужно контролировать количество потомков, тогда

Код


my $ChildCount = 0;
my $MaxChilds = 5;

#control and waiting signal from child process
$SIG{CHLD} = sub {while ( waitpid(-1, WNOHANG) > 0 ) { $ChildCount-- }}; 
...

while (1) {

  if ($ChildCount < $MaxChilds) { 
    ....
    $ChildCount++;

    my $pid = fork();

    unless ($pid) { 
      #потомок
      sleep(10);
    } else {
      #родитель
      #допустим print localtime, " : ", $ChildCount, "\n";
    }
  } else {
    sleep(5);
  }
}

Ну или просто как пример работы с форк... Писал "на коленке" мож есть необходимость в отладке.

Но учти, что при форке дочерний процесс создает полностью свою копию по переменным, поэтому из родителя ты еще можешь что-то передать в дочерний как переменную, но если ты изменишь эту переменную в дочернем, то в родительском ты уже не сможешь работать с измененной, и тем более что-то вернуть из дочернего процесса. smile

--------------------

менеджер по кодеврайтингу smile

GShadrin

Дата 1.12.2009, 18:32 (ссылка)

(нет голосов)

Загрузка ...

Шустрый

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

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

Спасибо за ответ.

Цитата(Bulat @ 1.12.2009, 17:48

)

А зачем ты так жестко-то с родителем??

Это взято из книги cookbook http://perl.find-info.ru/perl/015/socket/2.htm рецепт 17.11

Цитата(Bulat @ 1.12.2009, 17:48

)

я так понял что тебе нужно контролировать количество потомков

Не совсем. Подсчет количества подключенных я приводил в качестве примера. Мне необходимо иметь именно переменные общие для всех процессов, с возможностью изменения их в любом процессе. Как я понял такое невозможно.

Решил попробовать сделать на потоках theards используя эту же книгу.

Это сообщение отредактировал(а) GShadrin - 1.12.2009, 18:33

Pfailed

Дата 1.12.2009, 18:57 (ссылка)

(нет голосов)

Загрузка ...

Опытный

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

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

Для связи процессов используйте каналы или разделяемую память.

--------------------

I'm on CPAN
I'm on github

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