import multiprocessing
import time
def fun():
time.sleep(2)
print('----')
class T:
def __init__(self):
self.p = multiprocessing.Pool(4)
# @staticmethod
def fun(self):
time.sleep(3)
print('----')
def run(self):
for i in range(10):
self.p.apply_async(self.fun)
self.p.close()
self.p.join()
print('end')
if name == '__main__':
a = T()
a.run()