perl 线程中可以传递文件句柄么？

kelvenchi

我试着用

1. Thread::Queue

复制代码

传递，但是失败了。怎么才能在线程间传递已经打开的文件句柄呢？ 求高人解答，不甚感激。

kelvenchi

问题已解决，代码如下：

1. #! /usr/bin/perl
   
2. use strict;
   
3. use warnings;
   
4. use threads 'exit' => 'thread_only';
   
5. use threads::shared;
   
6. use Socket;
   
7. use Thread::Semaphore;
   
8. use Thread::Queue;
   
9. 
   
10. if (my $pid = fork) {
    
11.         exit;
    
12. } elsif ($pid = fork) {
    
13.         setpgrp;
    
14.         exit;
    
15. } else {
    
16. 
    
17.         my $fd    = Thread::Queue->new();
    
18.         my $rabbish = Thread::Queue->new();
    
19.         my $sem = Thread::Semaphore->new(100000);
    
20.         my $lis = threads->create(\&boss);
    
21.         my $jt = threads->create(\&joinThread);
    
22. 
    
23.         sub worker {
    
24.                 $sem->down;
    
25.                 my $fino = $fd->dequeue;
    
26.                 my @in;
    
27.                 open my $fhh, "<tserver.pl" or die "$!";
    
28.                 @in = <$fhh>;
    
29.                 close $fhh or die "$!";
    
30.                 open my $fh, ">&=$fino" or die "$!";   # 在这里把文件描述符，重新打开为文件句柄
    
31.                 while (@in) {
    
32.                         my $single = shift @in;
    
33.                         print $fh "$single";
    
34.                 }
    
35.                 print $fh "this message is from the server and the tid is " . threads->self->tid . "\n";
    
36.                 close $fh or die "$!";
    
37.                 $sem->up;
    
38.                 exit 1;
    
39.         }
    
40. 
    
41.         sub joinThread {
    
42.                 while (my $j = $rabbish->dequeue()) {
    
43.                         $j->join;
    
44.                 }
    
45.                 exit 1;
    
46.         }
    
47. 
    
48.         sub boss {
    
49.                         socket Server, AF_INET, SOCK_STREAM, getprotobyname 'tcp';
    
50.                         setsockopt Server, SOL_SOCKET, SO_REUSEADDR, 1;
    
51.                         my $paddr = sockaddr_in 8001, INADDR_ANY;
    
52.                         bind Server, $paddr;
    
53.                         listen Server, SOMAXCONN;
    
54.                         while (accept my $Client , Server) {
    
55.                                 select ((select($Client), $| = 1)[0]);
    
56.                                 $rabbish->enqueue(threads->create(\&worker));
    
57.                                 $fd->enqueue(fileno $Client);   # 这里把文件句柄转换成文件描述符
    
58.                         }
    
59.                 exit 1;
    
60.         }
    
61. 
    
62.         $lis->join;
    
63.         $jt->join;
    
64. }
    

复制代码

守护进程