У меня создаеться новый трид (прослушка в клиент-серверном приложении).
При создании трида я передаю указатель на $self:




но адресс $self-а принятого после запуска трида отличаеться от реального адреса (вообщем дубликат).
Эт конечно мне совсем не подходит. Мне нужно передать указатель что фсе работало синхронно.
Как это зделать?


ЗЫ: К Модераторам: А почему таги code не вставляються?

Это сообщение отредактировал(а) korob2001 - 24.1.2006, 19:20

Что-то я не пойму вопроса. Поясни подробнее, чего ты хочешь добиться?

а ты передавай референс(если я тебя конечно правельно понял)
пример

када передаю скалярные велечины или указатели на них все намана.
Но есе передаю екземпляр класа или даже референс, Пчемуто всегда создаеться дубликат((
При передачи референса это звучит как полный бред, но у меня это почемуто так

А как ты создаёшь потоки?

Вот, для примера, написал программу, которая создаёт 5 потоков ( не путать с процессами ) и ведёт одновременный поиск в пяти текстовых файлах, при этом каждый поток ведёт поиск того, что ему заданно, в часности:

Затем потоки собираются в один, после результаты поиска выводятся в STDOUT. Этот пример довольно растянут, но опять же это было сделано намерено, что бы он был более понятен.

Для того, что бы не озадачивать тебя поиском текста для файлов, прицепляю ZIP архив к этому посту. В нём находятся как текстовые файлы с текстом, так и сам исполняемый файл. Всё будет проходить довольно быстро, но если возникнет желание посмотреть на синхронизацию, то раскоментируй строки, которые я закоментировал в подпрограммах: tellLetters(), tellAll(), tellInt().

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

В отдельном потоке запускается подпрограмма tellLetters(), потоку передаём ссылку на неё. Далее через запятую передаём параметры в поток, в данном случае имя файла и искомую строку. Для работы с файлами я использовал модуль IO::File, для того, что бы было проще переписать этот пример для работы с сокетами, так как этот класс является производным от класса IO::Handle, так же как и класс IO::Socket. По нормальному ещё и не мешало бы блокировать потоки, если они используются для записи, с помощью lock().

Насколько я понял задачу, ты хочешь организовать прослушку на сервере, т.е. когда подключается клиет, то для него создаётся отдельный поток, в котором клиент и работает. Основной же поток так и продолжает ожидать нового подключения, если оно будет, то будет создан ещё один поток. Когда клиент отключается, то его поток соединяется обратно с основным потоком?

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

Это сообщение отредактировал(а) korob2001 - 26.1.2006, 22:00

Присоединённый файл ( Кол-во скачиваний: 5 )
 teller.zip 14,91 Kb

Догадки твои верны. Но приведенный тобой пример не совсем точен.

Клиент скидуеться на отдельный поток и запускаеться прослушка сообщениый от него.
Пакет присланный клиентом может быть одресован определенному клиенту. Знач должен быть зашареный объект, кторой ведет лист клиентов, и ряд утилитных фукнций.
При создании клиента и вещанья его метода onReciev в отдельном триде на прослушку, как аргумент для создания трида нуна передать указатель на самого себя.
Я передавал референс, но почемуто создавался клон. Воот тут и проблема.

Хтя, быть может это от того что я сижу на Винде. Всеже перл расчитан на юникс.


ЗЫ: Спасибо за помощь но тема исцерпана. Хтя разобраться былоб интересно.
Щас взялся за другую задачу. Этой занимаеться другой чел. Посмотрим как спаравиться.

У меня есть огромный список URL'ов, с которых нужно скачать страницы... Надо что бы программа качала их в несколько потоков. Какое число потоков оптимально? Например 10 потоков.. Как мне контролировать количество запущенных потоков, что бы их было всегда 10. Когда один отработал- запускался бы новый...



тут, как я понимаю, никакого контроля не ведется...

Например есть у меня массив @urls. В котором может быть большое количество элементов. Каждый элемент- URL адрес. Как мне запускать одну и ту же подпрограмму, что бы в памяти было определенное количество потоков. Каждому новому потоку передавать новый элемент этого массива в качестве параметра. И выполнять работу, пока все элементы массива не будут проработаны.
Добавлено @ 13:53
Кстати подпрограммка, которую я хочу многопоточно запускать довольно немаленькая... использует несколько модулей Perl. А на сервере стоит ограничение- 50 метров ОЗУ на программу....

Люди! Подскажите

rcdimon, к сожалению, я thread'ы на perl не программировал, не приходилось.
Могу рассказать про fork (распараллеливание отлично работает под nix), где-то здесь на форуме приводил функцию, которая скачивает страницы через прокси.


Добавлено @ 14:20
По тредам - perldoc Thread, perldoc threads.

Отлично. Мне не особо важно как будет происходить распаралеливание. Мне надо что бы просто подпрограмма, в задачу которой как раз входит закачка документов из сети и их обработка, запускалась многопоточно.

покажи пожалуйста пару примеров, или дай ссылку! Мне как я уже говорил надо поддерживать в памяти 10 потоков для обработки большого количества ссылок.



А в винде хоть немного работает? Я пишу на винде, но потом будет работать во FreeBSD... Хорошо бы что бы в винде работало хотя бы для разработки
Добавлено @ 14:29
И еще надо что бы не использовалось никаких нестандартных модулей

rcdimon,





perldoc -f fork, perlfork и посмотри особенности использования под Windows (в обще под win32 не работает).

а пример закачки страницы ищи на форуме.



Это сообщение отредактировал(а) sharq - 1.3.2006, 14:36

Искал- не нашел

rcdimon, плохо ищешь.
смотри здесь

Отлично.. единственное, чего я там не нашел- так это распаралеливание закачек.... а я именно это и просил

Создай массив с нужным числом потоков.
В примере выше, я сохранял потоки в хеше. Если посмотришь код, думаю создать массив потоков не составит особого труда. Единственное, что нужно добавить это код, который будет контролировать остались ли ещё ссылки в массиве или нет. Если да, то создаёшь поток в том элементе, который только что соединил, если нет, то просто соединяешь поток и ожидаешь завершения работы остальных потоков.
Если я чего-то не понял, поясни подробнее, чего ты хочешь добиться? Ты хочешь создавать зеркала html страниц или же ты хочешь заливать большие файлы в несколько потоков? Как например это делает ReGet Deluxe?

Это сообщение отредактировал(а) korob2001 - 1.3.2006, 23:30