threads的实现一定是有问题的

黑色阳光_cu

不管在Tk或者Gtk2里，只要一join或者detach，程序就崩溃了

1. #!/bin/env perl
   
2. 
   
3. use strict;
   
4. use warnings;
   
5. use threads;
   
6. use Tk;
   
7. 
   
8. my $mw = Tk::MainWindow->new();
   
9. my $btn = $mw->Button(-text => "hello", -command => sub
   
10. {
    
11.         my $t = threads->create(sub
    
12.         {
    
13.                 print "here\n";
    
14.         });
    
15. 
    
16.         $t->join();
    
17. })->pack();
    
18. 
    
19. Tk::MainLoop();
    

复制代码

1. #!/bin/env perl
   
2. 
   
3. use strict;
   
4. use warnings;
   
5. use threads;
   
6. use Gtk2;
   
7. use Glib qw(TRUE FALSE);
   
8. 
   
9. Glib::Object->set_threadsafe(TRUE);
   
10. Gtk2::Gdk::Threads->init();
    
11. Gtk2->init();
    
12. my $mw = Gtk2::Window->new();
    
13. my $btn = Gtk2::Button->new("Click me");
    
14. 
    
15. $mw->add($btn);
    
16. 
    
17. $btn->signal_connect(clicked => \&new_thread);
    
18. 
    
19. $mw->show_all();
    
20. Gtk2::Gdk::Threads->enter();
    
21. Gtk2->main();
    
22. Gtk2::Gdk::Threads->leave();
    
23. 
    
24. #####################################################
    
25. 
    
26. sub new_thread
    
27. {
    
28.         Gtk2::Gdk::Threads->enter();
    
29.         my $t = threads->create(\&hello);
    
30.         $t->detach();
    
31.         Gtk2::Gdk::Threads->leave();
    
32. }
    
33. 
    
34. sub hello
    
35. {
    
36.         print "say hello\n";
    
37. }
    

复制代码

黑色阳光_cu

能工作的写法只能是这样子：

1. #!/bin/env perl
   
2. 
   
3. use strict;
   
4. use warnings;
   
5. use threads;
   
6. use Thread::Queue;
   
7. 
   
8. my $queue = Thread::Queue->new();
   
9. threads->create(\&hello);
   
10. 
    
11. require Gtk2; import Gtk2;
    
12. require Glib; import Glib qw(TRUE FALSE);
    
13. sub TRUE();
    
14. sub FALSE();
    
15. 
    
16. Gtk2::Gdk::Threads->init();
    
17. Gtk2->init();
    
18. my $mw = Gtk2::Window->new();
    
19. my $btn = Gtk2::Button->new("Click me");
    
20. 
    
21. $mw->add($btn);
    
22. 
    
23. $btn->signal_connect(clicked => \&new_thread);
    
24. 
    
25. $mw->show_all();
    
26. Gtk2::Gdk::Threads->enter();
    
27. Gtk2->main();
    
28. Gtk2::Gdk::Threads->leave();
    
29. 
    
30. ##############################################
    
31. 
    
32. sub new_thread
    
33. {
    
34.         $queue->enqueue(1);
    
35. }
    
36. 
    
37. sub hello
    
38. {
    
39.         while ($queue->dequeue())
    
40.         {
    
41.                 my $t = threads->create(sub
    
42.                 {
    
43.                         print "say hello\n";
    
44.                 });
    
45. 
    
46.                 $t->detach();
    
47.         }
    
48. }
    

复制代码

iamlimeng

Perl的threads需要继续改进，期待下一版本解决这些问题。

wfnh

原来在这里·····
只能暂时用这个方案了···

laolun

回复 2# 黑色阳光_cu
借助你的想法，我稍作修改了下。可以在Gtk GUI界面上做widget更新;LWP抓取多网页内容

1. #!/bin/env perl
   
2. use strict;
   
3. use warnings;
   
4. use threads;
   
5. use Thread::Queue;
   
6. use LWP::Simple;
   
7. use Gtk2; import Gtk2;
   
8. use Glib; import Glib qw(TRUE FALSE);
   
9. use Gtk2::GladeXML;
   
10. Glib::Object->set_threadsafe(1);
    
11. Gtk2::Gdk::Threads->init();
    
12. Gtk2->init();
    
13. my @url;
    
14. foreach my $i(1..10){
    
15.     push(@url,"/search?q=%C7%EF%D7%B0&commend=all&ssid=s5-e&s=".42*$i."#J_FilterTabBar")
    
16. }
    
17. my $glade = Gtk2::GladeXML->new('lwp-thr.glade');
    
18. $glade->signal_autoconnect_from_package('main');
    
19. my $window = $glade->get_widget('window1');
    
20. $window->signal_connect('delete_event' => sub { Gtk2->main_quit; });
    
21. my $btn=$glade->get_widget('button1');
    
22. my $lab=$glade->get_widget('label1');
    
23. my $queue = Thread::Queue->new();
    
24. threads->create(\&run);
    
25. $btn->signal_connect(clicked=>\&new_thread);
    
26. $window->show_all();
    
27. Gtk2::Gdk::Threads->enter();
    
28. Gtk2->main();
    
29. Gtk2::Gdk::Threads->leave();
    
30. 
    
31. sub new_thread{
    
32.         $queue->enqueue(@url);
    
33. }
    
34. 
    
35. sub run{
    
36.         while (my $data=$queue->dequeue()){
    
37.                 my $t = threads->create(\&work,$data,$lab);
    
38.                 my $rt=$t->join();
    
39.                 print $rt."\n";
    
40.         }
    
41. }
    
42. sub work{
    
43.     my ($data,$lab)=@_;
    
44.     get_c($data);
    
45.     $lab->set_text("PROcessing $data");
    
46.     return $data;
    
47. }
    
48. sub get_c{
    
49.     my ($url)=@_;
    
50.     $url="http://s.taobao.com".$url;
    
51.     my $c=get($url);
    
52.     my $fn;
    
53.     if($url=~/s=(\d+)/){
    
54.         $fn=$1;
    
55.     }
    
56.     open(OUT,">$fn.htm") or die $!;
    
57.     print OUT $c;
    
58.     close(OUT);
    
59. }

复制代码

附上glade文件的代码：
文件名：lwp-thr.glade

1. <?xml version="1.0"?>
   
2. <glade-interface>
   
3.   <!-- interface-requires gtk+ 2.16 -->
   
4.   <!-- interface-naming-policy project-wide -->
   
5.   <widget class="GtkWindow" id="window1">
   
6.     <child>
   
7.       <widget class="GtkVBox" id="vbox1">
   
8.         <property name="visible">True</property>
   
9.         <property name="orientation">vertical</property>
   
10.         <child>
    
11.           <widget class="GtkLabel" id="label2">
    
12.             <property name="visible">True</property>
    
13.           </widget>
    
14.           <packing>
    
15.             <property name="position">0</property>
    
16.           </packing>
    
17.         </child>
    
18.         <child>
    
19.           <widget class="GtkButton" id="button1">
    
20.             <property name="label" translatable="yes">button</property>
    
21.             <property name="visible">True</property>
    
22.             <property name="can_focus">True</property>
    
23.             <property name="receives_default">True</property>
    
24.           </widget>
    
25.           <packing>
    
26.             <property name="position">1</property>
    
27.           </packing>
    
28.         </child>
    
29.         <child>
    
30.           <widget class="GtkLabel" id="label1">
    
31.             <property name="visible">True</property>
    
32.             <property name="label" translatable="yes">label</property>
    
33.           </widget>
    
34.           <packing>
    
35.             <property name="padding">18</property>
    
36.             <property name="position">2</property>
    
37.           </packing>
    
38.         </child>
    
39.       </widget>
    
40.     </child>
    
41.   </widget>
    
42. </glade-interface>
    

复制代码