子線程中執(zhí)行sleep(5),主線程也跟著sleep?

heidern

最近在研究多線程,想寫個(gè)服務(wù)器端程序.

1. #!/usr/local/perl5.12/bin/perl
   
2. use strict;
   
3. use warnings;
   
4. use threads (
   
5.         'exit' => 'threads_only',
   
6. );
   
7. use IO::Socket;
   
8. use Data::Dumper;
   
9. 
   
10. $|=1;
    
11. my $serverFD=IO::Socket::INET->new(
    
12.         LocalPort       =>      12340,
    
13.         Type            =>      SOCK_STREAM,
    
14.         Listen          =>      SOMAXCONN,
    
15.         Reuse           =>      1
    
16. ) || die $!;
    
17. 
    
18. # create a thread to monitor the threads
    
19. threads->create(\&threadMonitor);
    
20. 
    
21. # when a connect accepted , create a thread to process it
    
22. while (1) {
    
23.         threads->create(\&talk,$serverFD->accept());
    
24. }
    
25. 
    
26. sub talk
    
27. {
    
28.         my ($clientFD,$clientInfo)=@_;
    
29.         my ($clientport,$clientaddr) = unpack_sockaddr_in($clientInfo);
    
30.         my $clientip = inet_ntoa($clientaddr);
    
31.         my $tid = threads->self->tid();
    
32.         print "Client From => $clientip\:$clientport My number is $tid\n";
    
33.         while (<$clientFD>) {
    
34.                 print "client $tid from $clientip say: $_";
    
35.                 chomp($_);
    
36.                 if ($_ =~ m/hello/i) {
    
37.                         print $clientFD "tid=$tid,Hello Client from $clientip\n";
    
38.                 } elsif ($_ =~ m/bye/i) {
    
39.                         print $clientFD "tid=$tid,Bye Bye Client from $clientip\n";
    
40.                         close $clientFD;
    
41.                         last;
    
42.                 }
    
43.         }
    
44.         threads->self->detach();
    
45. }
    
46. 
    
47. sub threadMonitor
    
48. {
    
49.         print "Monitor Thread Created!!\n";
    
50.         while(1) {
    
51.                 my @ths_r=threads->list(threads::running);
    
52.                 my $threadNums_running=$#ths_r+1;
    
53.                 my @ths_j=threads->list(threads::joinable);
    
54.                 my $threadNums_joinable=$#ths_j+1;
    
55.                 print "There are $threadNums_running threads running and $threadNums_joinable threads joinable\n";
    
56.                 sleep(5);
    
57.         }
    
58.         threads->self->detach();
    
59. }
    
60. 
    

復(fù)制代碼

當(dāng)threadMonitor這個(gè)線程sleep的時(shí)候,主線程也會(huì)sleep,為什么?

另:我的測(cè)試方法是,先運(yùn)行這個(gè)腳本,然后開另外一個(gè)終端執(zhí)行下面的命令:
while(true);do echo "hello" |nc localhost 12340;done
剛開始執(zhí)行的時(shí)候還不錯(cuò),但server端執(zhí)行到sleep那的時(shí)候客戶端就會(huì)出現(xiàn)被阻塞的情況,5秒后就繼續(xù)了

flw

怎么就都這么迷信多線程呢。

cyril851122

一開始就該detach吧，要不主線程會(huì)等待子線程完成之后才繼續(xù)。 （我也不是很清楚，你自己試試)

cyril851122

一開始就該detach吧，要不主線程會(huì)等待子線程完成之后才繼續(xù)。 （我也不是很清楚，你自己試試)

heidern

試了,沒用..

cyril851122

我也裝了個(gè)perl試了下， 沒發(fā)現(xiàn)主線程被阻塞。我把sleep調(diào)到10了， 新客戶端連過來的時(shí)候立刻就有反應(yīng)。
windows 平臺(tái)下

heidern

我也裝了個(gè)perl試了下， 沒發(fā)現(xiàn)主線程被阻塞。我把sleep調(diào)到10了， 新客戶端連過來的時(shí)候立刻就有反應(yīng)。
...
cyril851122 發(fā)表于 2011-07-17 22:10

    我的系統(tǒng)是centos 5.6 64位的,
    我在原帖補(bǔ)充了我的測(cè)試方法.

cuteorange

回復(fù) 1# heidern

測(cè)試程序有問題。
    實(shí)際你只啟動(dòng)了一個(gè) nc localhost 12340 進(jìn)程

試試下邊的
while :; do echo -e 'hello' | nc localhost 12340&; done