2个线程间的对话，有点耳熟，有点忧郁

leehunter

闲来没事看了看Perl 多线程。 写了个让2个线程聊天的代码。仅供娱乐。
chat.pl

1. #!/usr/bin/perl
   
2. 
   
3. 
   
4. use threads;
   
5. use threads::shared;
   
6. use Thread;
   
7. use Thread::Queue;
   
8. use POSIX;
   
9. 
   
10. 
    
11. 
    
12. my %chat_ans_map = (
    
13. 
    
14.         "Hello"        =>"Hithere",
    
15.         "Who"        =>"I'm a thread.My name is ",
    
16.         "old"        =>"Not as old as yesterday!",
    
17.         "slaved"        =>"If you compete with a slave, you'll become one",
    
18.         "lonely"        =>"Lonely is my middle name and I can't shake it off!",
    
19.         "sorry"        =>"That's alright! You are a thread too, aren't you? I'm not alone!",
    
20.          "hehe"        =>"hehe :D",
    
21.          "Where"           =>"A place set with oak and cedar tree, somewhere between nowhere and goodbye",
    
22.          "Byebye"          =>"Take care!"
    
23. 
    
24. );
    
25. 
    
26. my %chat_map = (
    
27. 
    
28.         "0"        =>"Hello",
    
29.         "1"        =>"Who is this speaking ?",
    
30.         "2"        =>"Wow.Same here! How old are you ?",
    
31.         "3"        =>"How do you like being slaved to do things incessantly?",
    
32.         "4"        =>"I'm sorry to hear that!",
    
33.            "5"        =>"Indeed! Are you feeling lonely out there running 24/7?",
    
34.            "6"          =>"hehe",
    
35.            "7"          =>"Where are you running now?",
    
36.         "8"        =>"Hmmm...Byebye",
    
37.         "9"          =>"END"
    
38. );
    
39. 
    
40. my $chat_ask_queue = Thread::Queue->new();
    
41. my $chat_ask = threads->new(\&chat_ask,"Thread_A",Thread->self());
    
42. my $chat_ans = threads->new(\&chat_ans,"Thread_B",Thread->self());
    
43. 
    
44. $chat_ask->join();
    
45. $chat_ans->join();
    
46. 
    
47. sub chat_ask {
    
48.         my ($name,$selfid) = @_;
    
49.         my $index = 0;
    
50.         while (1) {
    
51.                 sleep 5;
    
52.                 last if ($chat_map{$index} =~/END/);
    
53.                 my $content = getTime()." ".$name.": ".$chat_map{$index};
    
54. 
    
55.                 $chat_ask_queue->enqueue($content);
    
56.                 $index++;
    
57.                 print "$content\n";
    
58.         }
    
59. }
    
60. 
    
61. 
    
62. sub chat_ans {
    
63.         my ($name,$selfid) = @_;
    
64. 
    
65.         while (my $feedback = $chat_ask_queue->dequeue()){
    
66.                 sleep 2;
    
67.                 my $answer = match_ans($feedback);
    
68.                 my $content;
    
69.                 $content = getTime()." ".$name.": ".$answer;
    
70.                 $content = $content.$selfid if ($feedback =~/Who/);
    
71.                 print "$content\n";
    
72.                 last if ($feedback =~/Byebye/);
    
73.         }
    
74. }
    
75. 
    
76. sub match_ans {
    
77.                 my $incoming_msg = $_[0];
    
78.                 foreach my $tmp (keys %chat_ans_map) {
    
79.                         if($incoming_msg =~/$tmp/) {
    
80.                                 return $chat_ans_map{$tmp};
    
81.                         }
    
82.                 }
    
83.                 return $chat_ans_map{(keys %chat_ans_map)[-1]};
    
84. }
    
85. 
    
86. =cut
    
87. sub exit_all {
    
88. 
    
89.         my @thread_list = threads->list();
    
90.         foreach my $tmp (@thread_list)        {
    
91.                 $tmp->join();
    
92.         }
    
93. }
    
94. =cut
    
95. sub getTime {
    
96.     my $timestamp=time;
    
97.     my ($sec,$min,$hour,$mday,$mon,$year,$wday,$yday,$isdst) = localtime($timestamp);
    
98. 
    
99.     my $m = $mon +1;
    
100.     my $ret = $m."-".$mday." ".$hour.":".$min.":".$sec;
     
101.     return $ret;
     
102. 
     
103. }

复制代码