multiprocessing.Pipe只有开始运行是对的,后面就乱了

yakczh_cu

1. #coding:utf-8
   
2. 
   
3. import multiprocessing
   
4. import time
   
5. from multiprocessing import Process,freeze_support
   
6. 
   
7. 
   
8. def proc1(pipe):
   
9.     i=0
   
10.     while True:
    
11.         i=i+1
    
12.         print "\nPROC1-SEND %s"%i
    
13.         pipe.send(i)
    
14.         
    
15.         time.sleep(3)
    
16.         print '\nPROC1-RECV:',pipe.recv()
    
17. def proc2(pipe):
    
18.     while True:
    
19.         print '\n\t\t\tproc2 recv:',pipe.recv()
    
20.         time.sleep(3)
    
21.         print "\n\t\t\tproc2 send %c"% 65
    
22.         pipe.send('A')
    
23. 
    
24. 
    
25. # Build a pipe
    
26. pipe = multiprocessing.Pipe(duplex=True)
    
27. #print pipe
    
28. 
    
29. # Pass an end of the pipe to process 1
    
30. p1   = multiprocessing.Process(target=proc1, args=(pipe[0],))
    
31. # Pass the other end of the pipe to process 2
    
32. p2   = multiprocessing.Process(target=proc2, args=(pipe[1],))
    
33. 
    
34. if __name__ == '__main__':
    
35.         freeze_support()
    
36.         p1.start()
    
37.         p2.start()
    
38.         p1.join()
    
39.         p2.join()

复制代码

输出结果
PROC1-SEND 1

                        proc2 recv: 1

PROC1-RECV:
                        proc2 send A

                        proc2 recv:A

PROC1-SEND 2
2

PROC1-RECV:
                        proc2 send A

jeppeter

回复 1# yakczh_cu

我测试你的代码，在python2上是完全正确，
在python3上，只要修改了print的代码，也是完全正确。所以不知道你是如何不正确的。

1. 
   
2. PROC1-SEND 1
   
3. 
   
4.                         proc2 recv: 1
   
5. 
   
6.                         proc2 send A
   
7. 
   
8. PROC1-RECV: A
   
9. 
   
10. PROC1-SEND 2
    
11. 
    
12.                         proc2 recv: 2
    
13. 
    
14.                         proc2 send A
    
15. 
    
16. PROC1-RECV: A
    
17. 
    
18. PROC1-SEND 3
    
19. 
    
20.                         proc2 recv: 3
    
21. 
    
22.                         proc2 send A
    
23. 
    
24. PROC1-RECV: A
    
25. 
    
26. PROC1-SEND 4
    
27. 
    
28.                         proc2 recv: 4
    
29. 
    
30.                         proc2 send A
    
31. 
    
32. PROC1-RECV: A
    
33. 
    
34. PROC1-SEND 5
    
35. 
    
36.                         proc2 recv: 5
    
37. 
    
38.                         proc2 send A
    
39. 
    
40. PROC1-RECV: A
    
41. 
    
42. PROC1-SEND 6
    
43. 
    
44.                         proc2 recv: 6
    
45. 
    
46.                         proc2 send A
    
47. 
    
48. PROC1-RECV: A
    
49. 
    
50. PROC1-SEND 7
    
51. 
    
52.                         proc2 recv: 7
    
53. 
    
54.                         proc2 send A
    
55. 
    
56. PROC1-RECV: A
    
57. 
    
58. PROC1-SEND 8
    
59. 
    
60.                         proc2 recv: 8
    

复制代码

yakczh_cu

回复 2# jeppeter

windows下试一下

jeppeter

回复 3# yakczh_cu

我测试了一下，还是对的。我用的系统是anaconda的python3.5 系统，在window7 x64系统下面。

yakczh_cu

回复 4# jeppeter
2.7呢, 这个是主流的版本