通道阻塞,使用了多线程也无用

3chi01

同http://bbs.chinaunix.net/thread-1272762-1-1.html
5分求助！

问二的继续：http://bbs.chinaunix.net/thread-1270279-1-1.html

按stop可以暂停了，但是图形界面显然通道阻塞了（不可控）使用了多线程也无用。继续请教各位高手！

use Win32::GUI qw();
use threads;

#create main window
my $main = Win32::GUI::Window->new(
    -name   => 'Main',
    -width  => 410,
    -height => 220,
    -text   => 'test',
         -maxsize => [410, 220],
  -minsize => [410, 220],
);

$Text_Informa=$main->AddTextfield(
    -name => "Text_Informa",
    -left => 10,
    -top  => 80,
    -width => 383,
    -height => 100,
    -multiline => 1,
);


$main->AddButton(-name => 'btnDown', -text => 'Download',-left => 265, -top => 45,);
$btnStop=$main->AddButton(-name => 'btnStop', -text => 'Stop',-left => 338, -top => 45,);


# initialization
my $w = $main->ScaleWidth();
my $h = $main->ScaleHeight();
my $desk = Win32::GUI::GetDesktopWindow();
my $dw = Win32::GUI::Width($desk);
my $dh = Win32::GUI::Height($desk);
my $x = ($dw - $w) / 2;
my $y = ($dh - $h) / 2;
$main->Move($x, $y);
$main->Show();

Win32::GUI:ialog();  
exit(0);

# window event handler
sub Main_Terminate {
    -1; #terminate the message loop
}

sub Main_Resize {
    $main->Resize($main->ScaleWidth - 20, $main->ScaleHeight - 40);
}   



sub btnDown_Click {
        my $thr = new threads(\&mythread );
        $thr->detach();
}



sub mythread {
$pg = 9;
while($pg > 1){
$Text_Informa->Append( "$pg\n";
sleep 1;
if($control==1){last;}
$pg--;
}}

sub EndIt {my  $con=shift; <>; $$con=1; return;  }   
#参考自[http://topic.csdn.net/t/20050503/16/3981999.html#[/url]
sub btnStop_Click { my $thr1 = new threads(\&mythread1); $thr1->join(); }
sub mythread1 {my $thd=new threads("EndIt",\$control); $thd->join(); }

[ 本帖最后由 3chi01 于 2008-9-22 11:57 编辑 ]

Rob

1. 
   
2. use strict;
   
3. use threads 1.39;
   
4. use threads::shared;
   
5. use Thread::Queue;
   
6. use Win32::GUI ();
   
7. 
   
8. # 最大线程数
   
9. my $Max :shared = 2;
   
10. # 退出程序标记
    
11. my $Quit :shared = 0;
    
12. # 线程开始标记
    
13. my $Start :shared = 0;
    
14. # 线程退出标记
    
15. my $Stop :shared = 0;
    
16. # 创建一个队列，线程间数据交换
    
17. my $q = Thread::Queue->new();
    
18. # 预建一个线程，用于线程管理
    
19. threads->create('waiter')->detach;
    
20. 
    
21. # GUI事件循环内不要放耗费CPU时间的操作
    
22. # 可以考虑将GUI会话单独放入一个线程
    
23. #create main window
    
24. my $main = Win32::GUI::Window->new(
    
25.         -name   => 'Main',
    
26.         -width  => 410,
    
27.         -height => 220,
    
28.         -text   => 'test',
    
29.         -maxsize => [410, 220],
    
30.         -minsize => [410, 220],
    
31. );
    
32. 
    
33. $main->AddTextfield(
    
34.         -name => "Text_Informa",
    
35.         -left => 10,
    
36.         -top  => 80,
    
37.         -width => 383,
    
38.         -height => 100,
    
39.         -multiline => 1,
    
40. );
    
41. 
    
42. $main->AddButton(-name => 'btnDown', -text => 'Download',-left => 265, -top => 45,);
    
43. $main->AddButton(-name => 'btnStop', -text => 'Stop',-left => 338, -top => 45,);
    
44. 
    
45. # initialization
    
46. my $w = $main->ScaleWidth();
    
47. my $h = $main->ScaleHeight();
    
48. my $desk = Win32::GUI::GetDesktopWindow();
    
49. my $dw = Win32::GUI::Width($desk);
    
50. my $dh = Win32::GUI::Height($desk);
    
51. my $x = ($dw - $w) / 2;
    
52. my $y = ($dh - $h) / 2;
    
53. $main->Move($x, $y);
    
54. $main->Show();
    
55. $main->AddTimer('T1', 100);
    
56. 
    
57. Win32::GUI::Dialog();  
    
58. exit(0);
    
59. 
    
60. sub waiter
    
61. {
    
62.         while (!$Quit) {
    
63.                 for (my $num = $Max - threads->list(); $num && $Start; $num--) {
    
64.                         threads->create('mythread');
    
65.                 }
    
66.                 sleep 1;
    
67.         }
    
68. }
    
69. 
    
70. sub mythread {
    
71.         my $pg = 9;
    
72.         while($pg > 1){
    
73.                 $q->enqueue($pg);
    
74.                 sleep 1;
    
75.                 if($Stop == 1){last;}
    
76.                 $pg--;
    
77.         }
    
78.     threads->detach();
    
79.     threads->exit();
    
80. }
    
81. 
    
82. # window event handler
    
83. sub Main_Terminate {
    
84.         $main->Hide();
    
85.         $Quit = $Stop = 0;
    
86.         sleep 1;
    
87.     -1; #terminate the message loop
    
88. }
    
89. 
    
90. sub Main_Resize {
    
91.     $main->Resize($main->ScaleWidth - 20, $main->ScaleHeight - 40);
    
92. }   
    
93. 
    
94. sub btnDown_Click {
    
95.         #my $thr = new threads(\&mythread );
    
96.         #$thr->detach();
    
97.         $Start = 1;
    
98.         $Stop = 0;
    
99. }
    
100. 
     
101. sub btnStop_Click {
     
102.         $Stop = 1;
     
103.         $Start = 0;
     
104. }
     
105. 
     
106. sub T1_Timer
     
107. {
     
108.         return unless $q->pending();
     
109.         my $p = $q->dequeue_nb();
     
110.         $main->{Text_Informa}->Append($p . "\n");
     
111. }
     
112. 
     
113. #sub EndIt {my  $con=shift; <>; $$con=1; return; }   
     
114. #参考自[[url]http://topic.csdn.net/t/20050503/16/3981999.html#[/url][/url]
     
115. #sub mythread1 {my $thd=new threads("EndIt",\$control); $thd->join(); }
     
116. 
     

复制代码

帮你改了改你的代码。
自己参考一下吧。

[ 本帖最后由 Rob 于 2008-9-24 19:52 编辑 ]

Rob

显然问题出在你用了“<>”， STDIN操作是一个I/O阻塞，在Win32下你不输入ENTER是没办法终止的，
*nix下你可以能过alarm+SIG去终止，但Win32下不可行。
不明白，既然你用了Win32-GUI，为何还需要控制台输入？ 仅仅为了测试？为何不在GUI中控件中获取输入？

如果一定要这样要，可以试试用Win32-Console
或者TermReadKey。

3chi01

原帖由 Rob 于 2008-9-22 14:51 发表
显然问题出在你用了“”， STDIN操作是一个I/O阻塞，在Win32下你不输入ENTER是没办法终止的，
*nix下你可以能过alarm+SIG去终止，但Win32下不可行。
不明白，既然你用了Win32-GUI，为何还需要控制台输入？ 仅 ...

多谢rob指点，学到好多知识。如何改下面的这句，请给一些意见，万分感谢！

sub EndIt {my  $con=shift; <>; $$con=1; return;  }   

我尝试去掉<>，还是一样的阻塞呀！

sub EndIt { return;  }   

[ 本帖最后由 3chi01 于 2008-9-22 18:05 编辑 ]

3chi01

是不是别的地方还有大毛病，搞不懂了。

[ 本帖最后由 3chi01 于 2008-9-22 18:18 编辑 ]

3chi01

多谢rob大侠，辛苦。万分感激中，我要好好消化一下了！

帮了我大忙。

3chi01

用rob大侠的代码很好用，但为什么刚开始每个数字出现两次呢，继续运行好像才会一次？
谢谢哪位老师解答。

1. use strict;
   
2. use threads 1.39;
   
3. use threads::shared;
   
4. use Thread::Queue;
   
5. use Win32::GUI ();
   
6. 
   
7. # 最大线程数
   
8. my $Max :shared = 2;
   
9. # 退出程序标记
   
10. my $Quit :shared = 0;
    
11. # 线程开始标记
    
12. my $Start :shared = 0;
    
13. # 线程退出标记
    
14. my $Stop :shared = 0;
    
15. # 创建一个队列，线程间数据交换
    
16. my $q = Thread::Queue->new();
    
17. # 预建一个线程，用于线程管理
    
18. threads->create('waiter')->detach;
    
19. 
    
20. # GUI事件循环内不要放耗费CPU时间的操作
    
21. # 可以考虑将GUI会话单独放入一个线程
    
22. #create main window
    
23. my $main = Win32::GUI::Window->new(
    
24.         -name   => 'Main',
    
25.         -width  => 410,
    
26.         -height => 220,
    
27.         -text   => 'test',
    
28.         -maxsize => [410, 220],
    
29.         -minsize => [410, 220],
    
30. );
    
31. 
    
32. $main->AddTextfield(
    
33.         -name => "Text_Informa",
    
34.         -left => 10,
    
35.         -top  => 80,
    
36.         -width => 383,
    
37.         -height => 100,
    
38.         -multiline => 1,
    
39. );
    
40. 
    
41. $main->AddButton(-name => 'btnDown', -text => 'Download',-left => 265, -top => 45,);
    
42. $main->AddButton(-name => 'btnStop', -text => 'Stop',-left => 338, -top => 45,);
    
43. 
    
44. # initialization
    
45. my $w = $main->ScaleWidth();
    
46. my $h = $main->ScaleHeight();
    
47. my $desk = Win32::GUI::GetDesktopWindow();
    
48. my $dw = Win32::GUI::Width($desk);
    
49. my $dh = Win32::GUI::Height($desk);
    
50. my $x = ($dw - $w) / 2;
    
51. my $y = ($dh - $h) / 2;
    
52. $main->Move($x, $y);
    
53. $main->Show();
    
54. $main->AddTimer('T1', 100);
    
55. 
    
56. Win32::GUI::Dialog();  
    
57. exit(0);
    
58. 
    
59. sub waiter
    
60. {
    
61.         while (!$Quit) {
    
62.                 for (my $num = $Max - threads->list(); $num && $Start; $num--) {
    
63.                         threads->create('mythread');
    
64.                 }
    
65.                 sleep 1;
    
66.         }
    
67. }
    
68. 
    
69. sub mythread {
    
70.         my $pg = 9;
    
71.         while($pg > 1){
    
72.                 $q->enqueue($pg);
    
73.                 sleep 1;
    
74.                 if($Stop == 1){last;}
    
75.                 $pg--;
    
76.         }
    
77.     threads->detach();
    
78.     threads->exit();
    
79. }
    
80. 
    
81. # window event handler
    
82. sub Main_Terminate {
    
83.         $main->Hide();
    
84.         $Quit = $Stop = 0;
    
85.         sleep 1;
    
86.     -1; #terminate the message loop
    
87. }
    
88. 
    
89. sub Main_Resize {
    
90.     $main->Resize($main->ScaleWidth - 20, $main->ScaleHeight - 40);
    
91. }   
    
92. 
    
93. sub btnDown_Click {
    
94.         #my $thr = new threads(\&mythread );
    
95.         #$thr->detach();
    
96.         $Start = 1;
    
97.         $Stop = 0;
    
98. }
    
99. 
    
100. sub btnStop_Click {
     
101.         $Stop = 1;
     
102.         $Start = 0;
     
103. }
     
104. 
     
105. sub T1_Timer
     
106. {
     
107.         return unless $q->pending();
     
108.         my $p = $q->dequeue_nb();
     
109.         $main->{Text_Informa}->Append($p . "\n");
     
110. }
     
111. 
     
112. #sub EndIt {my  $con=shift; <>; $$con=1; return; }   
     
113. #参考自[[url]http://topic.csdn.net/t/20050503/16/3981999.html#[/url][/url]
     
114. #sub mythread1 {my $thd=new threads("EndIt",\$control); $thd->join(); }

复制代码

[ 本帖最后由 3chi01 于 2009-2-10 09:18 编辑 ]