python 锁机制

lchl0388

#!/bin/usr/env python　　
#coding:utf-8
　　
import multiprocessing
　　
import time
　　
class multF(multiprocessing.Process):
　　
    """docstring for multF"""
　　
    def __init__(self,filename,proname,stime,lock):
　　
        multiprocessing.Process.__init__(self)
　　
        self.filename = filename
　　
        self.proname  = proname
　　
        self.stime    = stime
　　
        self.lock       = lock
　　
    def run(self):
　　
        with open(self.filename,'a') as f:
　　
            self.lock.acquire()
　　
            for x in xrange(1,5):
　　
                f.write("进程编号:"+str(self.proname)+"---"+str(x)+'\n')
　　
                time.sleep(self.stime)
　　
        f.close()
　　
        self.lock.release()
　　
        print u"文件写入完成."
　　
def main():
　　
    filename = './test2.txt'
　　
    lock = multiprocessing.Lock()
　　
    t1 = multF(filename,'01',2, lock)
　　
    t2 = multF(filename,'02',1,lock)
　　
    t3 = multF(filename,'03',2,lock)
　　
    t1.start()
　　
    t2.start()
　　
    t3.start()
　　
    t1.join()
　　
    t2.join()
　　
    t3.join()
　　
    print u"结束"
　　
if __name__ == '__main__':
　　
    main()