Релиб / Веб-программирование / Perl / thread queue shared variable problem, URGENT. / Latest Posts

RE: thread queue shared variable problem, URGENT.

DenisKa.ua — Sat, 23 Jul 2005 03:14:00 GMT

Thx for answer!Solved by using Thread::Queue:Any, which accept any stuructures ...

RE: thread queue shared variable problem, URGENT.

umbra — Fri, 22 Jul 2005 18:23:00 GMT

Tread::Queue не передает ссылок, только обычные типы(скаляры, списки, хэши). Вот это работает:[code]use threads;use Thread::Queue;#use Data::Dumper;my $queue = new Thread::Queue;$msg{'1'} = "Hello
";$msg{'2'}= "Word
";$queue->enqueue(%msg);my @gotit;while ($queue->pending) { push @gotit, $queue->dequeue_nb;}my %gotit = @gotit;print "gotit = @gotit
";print "1 : ".$gotit{'1'}; print "2: ".$gotit{'2'};[/code]

thread queue shared variable problem, URGENT.

DenisKa.ua — Thu, 21 Jul 2005 15:32:00 GMT

Hi guys, can anyone help me ?#I try to put in queue my recorduse threads;use Thread::Queue;use Data::Dumper;my $queue = new Thread::Queue; $msg{'1'} = "Hello
"; $msg{'2'}= "Word
"; $queue->enqueue(\%msg); $r = $queue->dequeue_nb; print "r = $r
"; print "1 : ".$r->{'1'}; print "2: ".$r->{'2'}; But I get error : Invalid value for shared scalar at c:\perl\lib\Queue.pm 90.When I remove use threads; code works OK.Any ideas how to put record in right way?But I need "use threads;" because without it my queue not sharingbetween threads.Following example illustrate what I mean#test for sharing queue between threadsuse threads;use Thread::Queue;use Data::Dumper;use Thread;my $queue = new Thread::Queue;sub th1 {while(1) { $queue->enqueue("msg from th1"); print "th1: ADDED ".$queue->pending."
"; sleep 2; }}sub th2 {while(1) { print "th2: REMOVED ".$queue->pending."
"; $queue->dequeue_nb; sleep 2;}}$th1 = new Thread(\&th1);$th2 = new Thread(\&th2); $th1->join;$th2->join;Code works OK. queue shared between threads.when I comment "use threads;" and run code, I can see that queue notshared between threads. Every thread have separated queue.How to solve it ?Thanks.