python中文件句柄的关闭问题

qqrilxk

谢谢 jeppeter大牛帮助
我现在改成了下面这个版本，它似乎能立即回收了。

1. import os,sys,time,multiprocessing,queue,threading,signal
   
2. pdict = {}
   
3. count = 0
   
4. 
   
5. 
   
6. def child(name,req):
   
7.         while True:
   
8.                 ret = 'a'
   
9.                 try:
   
10.                         ret = req.get(timeout=5)
    
11.                         print("%s get %s" %(name,ret))
    
12.                         time.sleep(2)
    
13.                         msg = "%s  exit now" %(name)
    
14.                         print(msg)
    
15.                         time.sleep(1)
    
16.                         req.close()
    
17.                         del req
    
18.                         os._exit(4)
    
19.                 except Exception as e:
    
20.                         print("child err,%s" %str(e))
    
21. 
    
22. def start_child(name,req):
    
23.         print("to start %s now" %name)
    
24.         p = multiprocessing.Process(target=child, args=(name,req) )
    
25.         p.start()
    
26.         pdict[name] = {}
    
27.         pdict[name]['queue'] = [req,p]
    
28.         pdict[name]['other'] = 'otherinfo'
    
29. 
    
30. 
    
31. def main():
    
32.         print(" main start now")
    
33.         req = ''
    
34.                
    
35.         #signal.signal(signal.SIGCHLD,signal.SIG_IGN)
    
36. 
    
37.         while True:
    
38.                 count = 0
    
39.                 while True:
    
40.                         count = count + 1
    
41.                         name = "child#%s" %count
    
42.                         req = multiprocessing.Queue()
    
43.                
    
44.                         print("\n")
    
45.                         print("start %s child now ......" %name)
    
46.                         p1 = threading.Thread( target=start_child,args = (name,req))                                                                                                                       
    
47.                         p1.start()
    
48. 
    
49.                         req.put([count])                       
    
50.                         time.sleep(4)                       
    
51. 
    
52.                         req = pdict[name]['queue'][0]
    
53.                         p = pdict[name]['queue'][1]
    
54.                         p.join()
    
55.                         req.close()
    
56.                         del req
    
57.                         del p
    
58.                         print("clear %s resource\n" %name)
    
59.                         pdict[name].pop('queue',None)
    
60.                         req = None
    
61.                         p = None
    
62.                         time.sleep(5)
    
63.                         print(" begin the %s round now #################" %(count+1))                                       
    
64. 
    
65. if __name__ == "__main__":
    
66.         main()
    

复制代码