匿名用戶

1級

2014-08-15 回答

可以每個在func中加上一個參數(shù)data,data是這個線程處理的數(shù)據(jù)；

多線程處理的時候，給每個線程分配相應(yīng)的data就可以了。

給個示例：

#?-*-?coding:utf-8?-*-

import?thread,threading

import?time

def?FuncTest(tdata):

print?tdata

class?mythread(threading.Thread):

def?__init__(self,threadname):

threading.Thread.__init__(self)

def?run(self):

lock.acquire()

FuncTest(ft)

lock.release()

def?MutiThread(num):

threads=[]

i=0

global?ft

for?x?in?xrange(num):

threads.append(mythread(num))

for?t?in?threads:

time.sleep(0.5)

lock.acquire()

ft=GetThreadParam(datafile,num,i)

#print?'[%s]Thread:%s,Testdata:%s'%(time.ctime(),t,ft)

i=i+1

t.start()

lock.release()

for?t?in?threads:

t.join()

def?GetThreadParam(datafile,?num,?curthread):

#線程數(shù)需要小于文件行數(shù)

f=open(datafile,'r')

lines=f.readlines()

divres=divmod(len(lines),num)

if?curthread>>

['1\n', '2\n', '3\n']

['4\n', '5\n', '6\n']

['7\n', '8\n', '9\n', '10']

總結(jié)

以上是生活随笔為你收集整理的python 多进程 循环_python 多进程读取同一个循环处理、可以用multiprocessing的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。