apple

th.py

@@ -81,7 +81,8 @@ def pRun(Cb,jobs,nm,ars):
         print(future.result()) # digest()の戻り値が表示される。
     # (上でas_completedをすべてイテレートしているので、実際にはこの時点で完了していないタスクは無いはず。)
     executor.shutdown()
-def thpoo(cb,urls,th=42,ve=()):
+#thpool
+def pool(cb,urls,th=23,ve=()):
     li2=[None]*len(urls)
     with ThreadPoolExecutor(max_workers=th) as executor:
         future_to_url = {executor.submit(cb, url,*ve): x for x,url in enumerate(urls)}
@@ -89,7 +90,7 @@ def thpoo(cb,urls,th=42,ve=()):
             x = future_to_url[future]
             li2[x]=future.result()
     return li2
-##print(thpe(lambda ab,cd:ab+"42",["A","B"],42,["CD"]))
+##print(thpe(lambda ab,cd:ab+"23",["A","B"],23,["CD"]))
 
 
 
@@ -125,7 +126,7 @@ def main():#incremental search
     for p in ps:
         p[0].start()
         time.sleep(0.5)
-##    print pare.recv()   # prints "[42, None, 'hello']"
+##    print pare.recv()   # prints "[23, None, 'hello']"
 ##    for p in ps:        jw(p,)
 
 if __name__ == '__main__':