Python用fork来创建子进程

今天看到别人的源代码中有fork子进程来操作数据。但是由于fork之后,没有及时的退出,导致系统中的进程越来越多,子进程越来越多了。自己随手写了Python下fork进程的测试代码(来说明这个问题不一定完全合适):

def fork(a):
    def now():
        import datetime
        return datetime.datetime.now().strftime("%S.%f")
    import os
    import time
    print now(), a
    if os.fork() == 0:
        print '子进程[%s]:%s' % (now(), os.getpid())
        while 1:
            a-=10
            print '子进程的a值[%s]:%s' % (now(), a)
            if a < 1:
                break
        print '准备退出子进程'
        #os._exit(0) ## 你可以在这里退出子进程
    else:
        print '父进程[%s]:%s' % (now(), os.getpid())
        while 1:
            a-=1
            print '父进程的a值[%s]:%s' % (now(), a)
            if a < 0:
                break
        time.sleep(1)
        print '等待子进程结束...'
        try:
            result = os.wait()
            if result:
                print '子进程:', result[0], result[1]
            else:
                print '没有数据!'
        except:
            print '异常哦...'
        print '父进程...'
    print '最后的值:',a
    #exit(0)  ## 你也可以在这里退出,注意,这里是父进程和子进程都共用的地方,在这里退出会导致父进程也一并退出

TIPS:

  1. os.fork() 会有两次返回值,分别是父进程和子进程的返回值
    • 在父进程中,返回的值是子进程的PID;
    • 子进程中,这个返回值为0
    • 子进程会复制父进程的上下文
    • 父子进程并不能确定执行顺序
  2. os.fork()之后,子进程一定要使用exit()或者os._exit()来退出子进程环境,建议使用os._exit()
  3. os.fork()来创建的这个代码并不是很通适,Linux是没问题的,在Windows下就是不能用的,而官方文档也有类似表述:
    Note that some platforms including FreeBSD <= 6.3, Cygwin and OS/2 EMX have known issues when using fork() from a thread
    
    Availability: Unix.
Wednesday, July 02, 2014 | 其他技术 编程语言

文章评论

No comments posted yet.

发表评论

Please add 4 and 5 and type the answer here:

关于博主

  一枚成分复杂的网络IT分子,属于互联网行业分类中的杂牌军。