pythonマルチプロセスを使用した関数パッケージの例
私は余計なことを言わないで、直接コードを見ましょう。
補足知識:pythonファイル内の複数の関数が同時に実行されます。
コードを見ましょう
次に同じようにスレッドt 2を作成し、t 2もthreads配列にセットする。
後記:
同時ブラウザの操作をしました。
パラメータ化をするなら、ddtを使うとすべての行為がブラウザで操作され、ddtフレームを外してから正常に進行します。
以上のpythonマルチプロセスは、関数パッケージの例を使用して、小编を共有しています。参考にしていただければと思います。どうぞよろしくお愿いします。
import multiprocessing as mp
from multiprocessing import Process
class MyProcess(Process):
"""
, Process, queue
"""
def __init__(self, func, args, q):
super(MyProcess, self).__init__()
self.func = func
self.args = args
self.res = ''
self.q = q
#self._daemonic = True
#self._daemonic = True
def run(self):
self.res = self.func(*self.args)
self.q.put((self.func.__name__, self.res))
def use_multiprocessing(func_list):
#os.system('export PYTHONOPTIMIZE=1') # daemonic processes are not allowed to have children
q = mp.Queue() # , , , multiprocessing queue
proc_list = []
res = []
for func in func_list:
proc = MyProcess(func['func'], args=func['args'], q=q)
proc.start()
proc_list.append(proc)
for p in proc_list:
p.join()
while not q.empty():
r = q.get()
res.append(r)
return res
使用する場合、多プロセス実行が必要な関数と関数のパラメータをフィールドとして、リストを作ってアメリカに送る。multiprocessing方法でいいです。補足知識:pythonファイル内の複数の関数が同時に実行されます。
コードを見ましょう
#coding=utf-8
import time
from selenium import webdriver
import threading
def fun1(a):
print a
def fun2():
print 222
threads = []
threads.append(threading.Thread(target=fun1,args=(u' ',)))
threads.append(threading.Thread(target=fun2))
print(threads)
if __name__ == '__main__':
for t in threads:
t.setDaemon(True) # selenium , ,
t.start()
import threading
まず、threadingモジュールを導入します。これはマルチスレッドを使用する前提です。
threads = []
t1 = threading.Thread(target=fun1,args=(u' ',))
threads.append(t1)
threads配列を作成し、スレッドt 1を作成し、threading.Thread()方法を用いて、この方法でmusic方法target=musicを呼び出し、args方法でmusicを転送する。作成したスレッドt 1をthreads配列にセットする。次に同じようにスレッドt 2を作成し、t 2もthreads配列にセットする。
for t in threads:
t.setDaemon(True)
t.start()
最後にforループで配列を巡回します。配列は、t 1とt 2のスレッドを搭載している)setDaemon()
set Daemen(True)はスレッドを守護スレッドとして宣言し、start()メソッドの呼び出し前に設定しなければならず、守護スレッドプログラムに設定しないと無限にマウントされます。子スレッドの起動後、親スレッドも継続して実行し、親スレッドが最後のステートメント「all over%s」%ctime()を実行した後、子スレッドを待つことなくそのまま終了し、同時に子スレッドも一緒に終了します。start()
スレッド活動を開始します。後記:
同時ブラウザの操作をしました。
パラメータ化をするなら、ddtを使うとすべての行為がブラウザで操作され、ddtフレームを外してから正常に進行します。
以上のpythonマルチプロセスは、関数パッケージの例を使用して、小编を共有しています。参考にしていただければと思います。どうぞよろしくお愿いします。