multiprocessing 错误

mrpre

打算每来一个请求，运行一个新开一个进程处理。我简化了一下程序
不知为什么错误，错误莫名其妙的。

1. 
   
2. 
   
3. def fun(num):
   
4.     print "OK!!!\n"+num
   
5. 
   
6. HOST = ''     #允许任何ip访问此服务器
   
7. PORT = 21888  #运行服务程序的端口                 
   
8. BUFSIZ = 1024                  
   
9. ADDR = (HOST,PORT)              
   
10. tcpSerSock = socket(AF_INET,SOCK_DGRAM)      
    
11. tcpSerSock.bind(ADDR)                          
    
12. 
    
13. 
    
14. while True:                                   
    
15.     print 'waiting for client connection...\n'
    
16. 
    
17.         data,addr = tcpSerSock.recvfrom(BUFSIZ)
    
18. 
    
19.         process = multiprocessing.Process(target=fun,args=(1,))//这行错误
    
20.         process.start()
    
21.         
    

复制代码

但是这么一个 程序是正确的，不知道是为什么：

1. import multiprocessing
   
2. import time
   
3. 
   
4. def clock(interval):
   
5.             while True:
   
6.               print("The time is {0}".format(time.ctime()))
   
7.               time.sleep(interval)
   
8. 
   
9. 
   
10. p = multiprocessing.Process(target=clock, args=(15,))
    
11. p.start()
    

复制代码

mrpre

一开始以为客户端发了太多请求，所以错误，后来客户端变成发一个udp，但还是错误

mrpre

处理循环的话，必须要加：if __name__=='__main__':