from multiprocessing import Process
def fun1(name):
print(‘测试%s多进程‘ %name)
if __name__ == ‘__main__‘:
process_list = []
for i in range(5): #开启5个子进程执行fun1函数
p = Process(target=fun1,args=(‘Python‘,)) #实例化进程对象
p.start()
process_list.append(p)
for i in process_list:
p.join()
print(‘结束测试‘)
from multiprocessing import Process,Pool
def fun1(name):
print(‘Run task %s (%s)...‘ % (name, os.getpid()))
start = time.time()
time.sleep(random.random() * 3)
end = time.time()
print(‘Task %s runs %0.2f seconds.‘ % (name, (end - start)))
if __name__==‘__main__‘:
pool = Pool(5) #创建一个5个进程的进程池
for i in range(10):
pool.apply_async(func=fun1, args=(i,)) #apply是同步,apply_async是异步
pool.close()
pool.join()
print(‘结束测试‘)
import threading
def fun1(name):
print(‘测试%s多线程‘ %name)
if __name__ == ‘__main__‘:
for i in range(10):
t = threading.Thread(target=fun1, args=(str(i),))
t.start()
原文:https://www.cnblogs.com/peng-yuan/p/15182545.html