多線程copy

bintre

1. #!/usr/bin/perl
   
2. use strict;
   
3. use warnings;
   
4. use threads;
   
5. use threads::shared;
   
6. use Thread::Queue;
   
7. use File::Find;
   
8. use Benchmark;
   
9. use File::Copy;
   
10. my ($time_start,$time_end);
    
11. $time_start=new Benchmark;
    
12. my $infile = new Thread::Queue;
    
13. my $MAX_THREADS = 10;
    
14. for (my $n = 0; $n < $MAX_THREADS; $n++)
    
15. {
    
16.         threads->create(\&thread_copy);
    
17. }
    
18. 
    
19. find(\&wanted,"./");
    
20. sub wanted {
    
21.         my $file;
    
22.         $file=$File::Find::name;
    
23.         $infile->enqueue($file);
    
24.         if($infile->pending() > $MAX_THREADS * 5){
    
25.                 sleep 1;
    
26.                
    
27.         }
    
28.        
    
29. }
    
30. 
    
31. while($infile->pending() > 0){
    
32.         sleep 1;
    
33. }
    
34. 
    
35. $time_end=new Benchmark;
    
36. my $usetm=timediff($time_end, $time_start);
    
37. print "use time: ", timestr($usetm), "\n";
    
38. print "Press Enter to exit ...";
    
39. <STDIN>;
    
40. 
    
41. foreach my $thread (threads->list(threads::all))
    
42. {       
    
43.         $thread->detach();
    
44. }
    
45. 
    
46. sub thread_copy{
    
47.         while( my $file=$infile->dequeue()){
    
48.         print "$file\n";
    
49.         File::Copy::copy($file,"~/tmp");
    
50.         }
    
51. }
    

復(fù)制代碼

文件太多了。整個(gè)多線程的。各位看看有缺陷嗎？