python多进程（ 永远删除不完的文件 ）+ 进度条打印

Cool_Breeze

1. # 永远删不完的文件
   
2. # BY GIN
   
3. # 2020-7-31
   
4. 
   
5. #coding=utf-8
   
6. 
   
7. import os
   
8. from multiprocessing import Process, Queue
   
9. import time
   
10. import random
    
11. 
    
12. PH = r'D:\GIN\py\test\temp'
    
13. Q = Queue()
    
14. 
    
15. def random_del():
    
16.     # 随机删除一个文件
    
17.     os.chdir(PH)
    
18.     while True:
    
19.         time.sleep(0.5)
    
20.         file = str(random.Random.randint(random,1,10)) + '.txt'
    
21.         if os.path.isfile(file):
    
22.             print('随机删除一个文件：{}'.format(file))
    
23.             os.remove(file)
    
24.         
    
25. 
    
26. def supplement_t(Q):
    
27.     # 补充缺失文件
    
28.     os.chdir(PH)
    
29.     while True:
    
30.         time.sleep(0.5)
    
31.         # print('get {:>2}'.format(Q.qsize()))
    
32.         while not Q.empty():
    
33.             file = Q.get()
    
34.             print('正在补充缺失文件：{}'.format(file))
    
35.             with open(file, "w") as f:
    
36.                 pass
    
37. 
    
38. 
    
39. def chec_txt(Q):
    
40.     # 检查文件是否缺失。
    
41.     # 如果文件缺失，向补充文件函数发送
    
42.     # 缺失文件。
    
43.     os.chdir(PH)
    
44.     while True:
    
45.         for i in (range(1,11)):
    
46.             time.sleep(0.3)
    
47.             file = str(i) + '.txt'
    
48.             if not os.path.isfile(file):
    
49.                 Q.put(file)
    
50.                 # print('put {:>2}'.format(Q.qsize()))
    
51.    
    
52. 
    
53. def generate_txt():
    
54.     # 创建所有文件。
    
55.     os.chdir(PH)
    
56.     for i in range(1,11):
    
57.         file = str(i) + '.txt'
    
58.         print('touch  {:>6}'.format(file))
    
59.         with open(file, "w") as f:
    
60.             pass
    
61. 
    
62.    
    
63. if __name__ == '__main__':
    
64.     gen_p = Process(target=generate_txt)
    
65.     che_p = Process(target=chec_txt, args=(Q,))     # 需要传入相同的对象
    
66.     get_p = Process(target=supplement_t, args=(Q,))   # 需要传入相同的对象
    
67.     rad_p = Process(target=random_del)
    
68.     gen_p.start()
    
69.     che_p.start()
    
70.     get_p.start()
    
71.     rad_p.start()
    
72.     # 主进程会等待所有进程结束

复制代码

result：

1. touch   1.txt
   
2. touch   2.txt
   
3. touch   3.txt
   
4. touch   4.txt
   
5. touch   5.txt
   
6. touch   6.txt
   
7. touch   7.txt
   
8. touch   8.txt
   
9. touch   9.txt
   
10. touch  10.txt
    
11. 随机删除一个文件：5.txt
    
12. 随机删除一个文件：6.txt
    
13. 随机删除一个文件：1.txt
    
14. 正在补充缺失文件：5.txt
    
15. 正在补充缺失文件：6.txt
    
16. 随机删除一个文件：3.txt
    
17. 随机删除一个文件：9.txt
    
18. 随机删除一个文件：4.txt
    
19. 正在补充缺失文件：1.txt
    
20. 随机删除一个文件：2.txt
    
21. 正在补充缺失文件：3.txt
    
22. 正在补充缺失文件：4.txt
    
23. 随机删除一个文件：1.txt

复制代码

####

1. '''
   
2. @ 进度条打印
   
3. '''
   
4. 
   
5. #coding=utf-8
   
6. 
   
7. from time import sleep
   
8. from multiprocessing import Process,Queue
   
9. 
   
10. q = Queue()
    
11. 
    
12. ico = [
    
13.     ['0%',''],
    
14.     ['10%','X'],
    
15.     ['20%','XX'],
    
16.     ['30%','XXX'],
    
17.     ['40%','XXXX'],
    
18.     ['50%','XXXXX'],
    
19.     ['60%','XXXXXX'],
    
20.     ['70%','XXXXXXX'],
    
21.     ['80%','XXXXXXXX'],
    
22.     ['90%','XXXXXXXXX'],
    
23.     ['100%\n','XXXXXXXXXX'],
    
24.     ]
    
25. 
    
26. def run(q):
    
27.     while True:
    
28.         if not q.empty():
    
29.             t = q.get()
    
30.             if t == None: break
    
31.             print('\r{:<10}{}'.format(t[1],t[0]),end='',flush=True)
    
32.    
    
33.    
    
34. if __name__ == "__main__":
    
35.     n = 0
    
36.     arr = []
    
37.     p = Process(target=run,args=(q,))
    
38.     p.start()
    
39.     print('开始计算 1 累加到 10 ：')
    
40.     for i in range(11):
    
41.         n += i
    
42.         q.put(ico[i])
    
43.         sleep(0.2)
    
44.     q.put(None)
    
45.     p.join()
    
46.     print('计算 1 累加到 10 完成：{}'.format(n))
    
47.    

复制代码

_2_

Emmmmm 应该没什么用

Cool_Breeze

_2_ 发表于 2020-7-31 17:31
Emmmmm 应该没什么用

或许，可以改一改？

Cool_Breeze

_2_ 发表于 2020-7-31 17:31
Emmmmm 应该没什么用

学习多进程，感觉不得劲，总是要有项目才有力量！所有就写了个这！