import multiprocessing
from opencc import OpenCC
class a(object):
def func1(self, i):
return i
def test(self, total):
multiprocessing.freeze_support() # for windows, RuntimeError
pool = multiprocessing.Pool(1)
result = []
for i in range(total):
res = pool.apply_async(self.func1, args=(i,))
result.append(res)
pool.close()
self.aa = OpenCC('s2twp')
for idx, r in enumerate(result,start=1):
print (r.get())
print('{}/{}'.format(idx, total), end='\r')
print ('')
if __name__ == '__main__':
o = a()
o.test(700)
aW1wb3J0IG11bHRpcHJvY2Vzc2luZwppbXBvcnQgdGltZQpmcm9tIG9wZW5jYyBpbXBvcnQgT3BlbkNDCgpjbGFzcyBhKG9iamVjdCk6CiAgZGVmIGZ1bmMxKHNlbGYsIGkpOgogICAgcmV0dXJuIGkKCiAgZGVmIHRlc3Qoc2VsZiwgdG90YWwpOgogICAgbXVsdGlwcm9jZXNzaW5nLmZyZWV6ZV9zdXBwb3J0KCkgICMgZm9yIHdpbmRvd3MsIFJ1bnRpbWVFcnJvcgogICAgcG9vbCA9IG11bHRpcHJvY2Vzc2luZy5Qb29sKDEpCgogICAgc3RhcnRpbWUgPSB0aW1lLnRpbWUoKQogICAgcmVzdWx0ID0gW10KICAgIGZvciBpIGluIHJhbmdlKHRvdGFsKToKICAgICAgcmVzID0gcG9vbC5hcHBseV9hc3luYyhzZWxmLmZ1bmMxLCBhcmdzPShpLCkpCiAgICAgIHJlc3VsdC5hcHBlbmQocmVzKQoKICAgIHBvb2wuY2xvc2UoKQogICAgc2VsZi5hYSA9IE9wZW5DQygnczJ0d3AnKQoKICAgIGZvciBpZHgsIHIgaW4gZW51bWVyYXRlKHJlc3VsdCxzdGFydD0xKToKICAgICAgcHJpbnQgKHIuZ2V0KCkpCiAgICAgIHByaW50KCd7fS97fScuZm9ybWF0KGlkeCwgdG90YWwpLCBlbmQ9J1xyJykKICAgIHByaW50ICgnJykKICAgIHByaW50ICgndGltZT0nLCB0aW1lLnRpbWUoKS1zdGFydGltZSkKCmlmIF9fbmFtZV9fID09ICdfX21haW5fXyc6CiAgbyA9IGEoKQogIG8udGVzdCg3MDAp