[solved]socket:thread pool:something is wrong

os4fun

打算弄个简单的c/s跑个小东西，几行代码的小demo也要坚定的出错啊:wink:

c从s读取时间。

c 串行读取的时候一切正常。
c 多线程，部分连接读不到任何东西。ARGV[0]越大，失败越多。
两边warn出来的信息看，双方都认为连接出了问题。

我甚至上了wireshark ，所有的连接都成功建立。问题连接还没传送任何东西就被 s 主动关闭。c自然读不到，s也写不出去。

--udpate--
原因找到,很弱智. srv:

1. for (my $i = 0;; $i++) {
   
2.         $cli = $socket->accept or die $!;
   
3.         #这里的$cli生命期仅仅在这次循环里,下次循环的时候$cli被重新赋值,上一次的值会被释放,也就是句柄被放掉了.
   
4.         $tp->add(fileno($cli), $i);
   
5. }

复制代码

-------

1. #!/usr/bin/perl -w
   
2. # cli
   
3. use 5.010;
   
4. use strict;
   
5. use IO::Socket;
   
6. use Thread::Pool::Simple;
   
7. 
   
8. sub get_date {
   
9.         my $socket = new IO::Socket::INET( PeerAddr => '127.0.0.1:9000') or warn $!;
   
10.         #sleep 1;
    
11.         say shift, (<$socket> or warn $!); #Warning: something's wrong
    
12. }
    
13. 
    
14. #get_date($_) for (0 .. $ARGV[0] || 10);
    
15. 
    
16. my$tp = Thread::Pool::Simple->new(min=>10,max=>20,load=>10,do=>[\&get_date]);
    
17. $tp->add($_) for (0 .. $ARGV[0] || 10);
    
18. $tp->join();
    

复制代码

1. #!/usr/bin/perl -w
   
2. # srv
   
3. use 5.010;
   
4. use strict;
   
5. use POSIX;
   
6. use IO::Socket;
   
7. use Thread::Pool::Simple;
   
8. 
   
9. my $socket = new IO::Socket::INET(LocalAddr=>'127.0.0.1:9000', Listen=>10, Reuse=>1) or die $!;
   
10. 
    
11. sub day_svc {
    
12.         my ($fileno, $i) = @_;
    
13.         open my $cli, ">&=$fileno" or warn $!; #warn:Bad file descriptor
    
14.         print $cli scalar localtime; #warn:print() on closed filehandle
    
15.         close $cli;
    
16.         POSIX::close $fileno;
    
17.         say "$i done";
    
18. }
    
19. 
    
20. my $tp = Thread::Pool::Simple->new(min=>30,max=>50,load=>10,do=>[\&day_svc]);
    
21. 
    
22. my $cli;
    
23. for (my $i = 0;; $i++) {
    
24.         $cli = $socket->accept or die $!;
    
25.         $tp->add(fileno($cli), $i);
    
26. }
    
27. 
    
28. $tp->join();
    

复制代码