Python多线程编程之多线程加锁操作示例

# -*- coding:utf-8 -*-#! python2import threadingstart_task = 0task_num = 10000mu = threading.Lock()  ###通过工厂方法获取一个新的锁对象class MyThread(threading.Thread):  ###类MyThread继承基类threading.Thread  def run(self): ##线程启动的入口函数，子类需重写    global start_task    global mu    global start_task    while start_task < task_num:  ##如果任务没有完成，则继续      if mu.acquire():  ##加锁        if start_task < task_num:          print start_task          start_task = start_task + 1        mu.release()  ##释放锁def test():  thread_all = []  for i in range(6): ##for循环创建6个线程    t = MyThread() ##创建线程    thread_all.append(t)    t.start()  ###启动线程  for i in range(6):    thread_all[i].join()  ##等待线程结束if __name__ == "__main__":  test()