my @data_array = split( /;/, $data ); foreach (@data_array) { return "$_\n"; ############################################################### print "$_\n"; } #### #!/usr/bin/perl -- ## perltidy -olq -csc -csci=10 -cscl="sub : BEGIN END" -otr -opr -ce -nibc -i=4 -pt=0 "-nsak=*" use strict; use warnings; use threads stack_size => 4096; use Thread::Queue; Main( @ARGV ); exit( 0 ); sub Main { my $qin = Thread::Queue->new(); ## jobs to do in background my $qout = Thread::Queue->new(); ## results for gui in foreground ## don't wait for background downloading service workers / mechtitles threads->create( \&mechtitles, $qin, $qout ) for 1 .. 2; tkgui($qin, $qout ); ## run gui in main thread, wait for it to finish return; } ## end sub Main sub mechtitles { my( $qin, $qout ) = @_; eval { threads->detach() } ; ## can't join this thread it returns nothing :) require WWW::Mechanize; require Time::HiRes; my $gets = 0; while( 1 ) { #~ if( defined( my $url = $qin->popnow ) ) { if( defined( my $url = $qin->pop ) ) { my $ua = WWW::Mechanize->new( autocheck => 0 ); $ua->get( $url ); my $title = eval { $ua->title }; $title ||= $ua->res->status_line; $gets++; my $worker = sprintf 'worker(%s)(%s)', threads->tid, $gets; $qout->push( "$worker $url =>\n $title\n" ); } Time::HiRes::usleep( 33 * 1000 ); ## sleep microseconds ## be "nice" give other thread a time slice } } ## end sub mechtitles sub tkgui { my( $qin, $qout ) = @_; require Tk; #~ require Tk::ROText; my $mw = Tk::tkinit(); my $pending = ""; my $l = $mw->Label( -textvariable => \$pending )->pack; #~ my $t = $mw->ROText()->pack; my $t = $mw->Text()->pack; my $b = $mw->Button( -text => 'enqueue another 4 example.com', )->pack; $b->configure( -command => [ \&q_pusher, $b, $qin, \$pending ], ); $b->focus; $mw->repeat( 100, ## milliseconds [ \&pop_to_pending, $t, \$pending, $qin, $qout, ], ); $mw->MainLoop; return; } ## end sub tkgui sub q_pusher { my( $b, $qin, $pending ) = @_; $qin->push( 'http://example.com' ) for 1 .. 4; #~ $b->configure( -state => "disabled" ); return; } sub pop_to_pending { my( $t, $pending, $qin, $qout ) = @_; $$pending = 'Jobs awaiting workers ' . $qin->pending; if( defined( my $item = $qout->popnow ) ) { $t->insert( q!end!, join( '', $item ) ); $t->see('end'); } $$pending = 'Jobs awaiting workers ' . $qin->pending; $t->update; return; } sub Thread::Queue::append { goto &Thread::Queue::enqueue } sub Thread::Queue::remove { goto &Thread::Queue::dequeue } sub Thread::Queue::push { goto &Thread::Queue::enqueue } sub Thread::Queue::shift { goto &Thread::Queue::dequeue } sub Thread::Queue::popnow { goto &Thread::Queue::dequeue_nb } sub Thread::Queue::pop { goto &Thread::Queue::dequeue } __END__