23 python多线程threading及线程同步

################   多线程应用举例  写法1：  ####################################################
import threading
from time import ctime,sleep

def func1():
    for i in range(5):
        print "i={}".format(i)
        sleep(1)

def func2():
    for j in range(5):
        print "j={}".format(j)
        sleep(1)

def main():
    print("start:",ctime())
    t1=threading.Thread(target=func1)
    t2=threading.Thread(target=func2)

    t1.start()
    t2.start()

    t1.join()
    t2.join()   ## 这里最好是加join函数，因为如果不加，则不等前面执行完，则pint这个后面语句则会被执行（不会等待）
    print '11111'  ## 即如果不加，则主线程不会等待子线程是否执行完

if __name__ == '__main__':
    main()




################   多线程应用举例  写法2：  ####################################################


import threading
from time import ctime,sleep

def func1():
    for i in range(5):
        print "i={}".format(i)
        sleep(1)

def func2():
    for j in range(5):
        print "j={}".format(j)
        sleep(1)


class mythread(threading.Thread)   ##继承threading类，
    def __init__(self,func):
        threading.Thread.__init__(self)
        self.func=func

    def run(self):
        self.func()

def main():
    print("start:",ctime())
    t1=mythread(func1)
    t2=mythread(func2)

    t1.start()
    t2.start()

    t1.join()
    t2.join()   ## 这里最好是加join函数，因为如果不加，则不等前面执行完，则pint这个后面语句则会被执行（不会等待）
    print '11111'  ## 即如果不加，则主线程不会等待子线程是否执行完

if __name__ == '__main__':
    main()


########################## 线程同步  ################################################################
说明：
    多个进程同时操作一个资源，需要有线程同步，防止同时修改或访问，这样会造成数据错误。
    如果不涉及操作同一个资源，（则也没有必要线程同步，只用多线程即可）


## 线程的同步
import threading
from time import sleep

tickets=100

class Window(threading.Thread):
    """docstring for Window."""
    def __init__(self, n,lock):
        self.lock=lock
        threading.Thread.__init__(self,name=n) ## 调用父类的构造方法
    def take(self):
        global tickets
        while tickets>=1:
            self.lock.acquire()  ##加锁

            print ("%s:%d" %(threading.currentThread().name,tickets))
            tickets=tickets-1

            self.lock.release() ##释放锁
            sleep(1)

    def run(self):   ## 复写你类的RUN函数，即覆盖了父类的run函数
        self.take()


def main():
    lock=threading.Lock()
    for i in range(1,5):  ## 有4个窗口同时卖票
        name='w'+str(i)   ## 定义窗口名字
        w=Window(name,lock)  ##此窗口开始卖票（参数为窗口名，和锁对象）,因为实例化的线程类，所以有5个线程
        w.start()  ## 调用父类的start方法

if __name__ == '__main__':
    main()

------------------- 使用上下文管理器 with 进行同步---------------------

说明：
    还可以使用with时lock的作用载，上面的代码lock.acquire() 和 lock.release()之间的代码 ，使用with包含即可。

## 线程的同步
import threading
from time import sleep

tickets=100

class Window(threading.Thread):
    """docstring for Window."""
    def __init__(self, n,lock):
        self.lock=lock
        threading.Thread.__init__(self,name=n) ## 调用父类的构造方法
    def take(self):
        global tickets
        while tickets>=1:
            # self.lock.acquire()  ##加锁
            with self.lock:      ## 使用with上下文管理器
                print ("%s:%d" %(threading.currentThread().name,tickets))
                tickets=tickets-1

            # self.lock.release()  ##释放锁
            sleep(1)

    def run(self):   ## 复写你类的RUN函数，即覆盖了父类的run函数
        self.take()


def main():
    lock=threading.Lock()
    for i in range(1,5):  ## 有5个窗口同时卖票
        name='w'+str(i)   ## 定义窗口名字
        w=Window(name,lock)  ##此窗口开始卖票（参数为窗口名，和锁对象）,因为实例化的线程类，所以有5个线程
        w.start()  ## 调用父类的start方法

if __name__ == '__main__':
    main()

--------------------- 使用信号量控制线程 --------------------------------