Python Multiprocessing问题 10

为什么我创建多进程后,子进程运行完成后不自动退出来啊,而是变成死进程,为Sl+状态,只有父进程完成后,子进程才退出?如何让子进程完成后自动退出来啊。... 为什么我创建多进程后,子进程运行完成后不自动退出来啊,而是变成死进程,为 Sl+状态,只有父进程完成后,子进程才退出?如何让子进程完成后自动退出来啊。 展开
 我来答
Lovesoo
2014-08-15 · TA获得超过2385个赞
知道小有建树答主
回答量:654
采纳率:66%
帮助的人:414万
展开全部

给个示例:


# -*- 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):
    #线程数需要小于文件行数
    f=open(datafile,'r')
    lines=f.readlines()
    divres=divmod(len(lines),num)
    if curthread<(num-1):
        res=lines[curthread*divres[0]:(curthread+1)*divres[0]]
    elif curthread==(num-1):
        res=lines[curthread*divres[0]:((curthread+1)*divres[0]+divres[1])]
    return res
    f.close()
     
if __name__ == '__main__':
     
    global num,lock
    datafile='a.txt'
     
    num=3  #num 并发数
     
    lock=threading.Lock()
    MutiThread(num)

a.txt文件内容如下

1

2

3

4

5

6

7

8

9

10


3个线程并发时,运行结果:

>>> 

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

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

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

温柔_圇砊噽58
2014-08-15 · 超过68用户采纳过TA的回答
知道答主
回答量:196
采纳率:0%
帮助的人:70.1万
展开全部
把错误截出来!!!
已赞过 已踩过<
你对这个回答的评价是?
评论 收起
推荐律师服务: 若未解决您的问题,请您详细描述您的问题,通过百度律临进行免费专业咨询

为你推荐:

下载百度知道APP,抢鲜体验
使用百度知道APP,立即抢鲜体验。你的手机镜头里或许有别人想知道的答案。
扫描二维码下载
×

类别

我们会通过消息、邮箱等方式尽快将举报结果通知您。

说明

0/200

提交
取消

辅 助

模 式