python进程线程

import threading
import time
#################不使用多线程############
#如果不使用多线程,只执行两边f1函数 需要两秒
def f1(arg):
    time.sleep(1) #停一秒
    print(arg)
f1(1)
f1(2)
##############使用多线程################
#如果使用多线程,会同时执行函数，需要一秒
t1 = threading.Thread(target=f1,args=(1,)) #这个是线程
t1.start()
t2 = threading.Thread(target=f1,args=(2,))
t2.start()

import threading
import time
NUM = 10
def func(l):
    global NUM
    l.acquire()  #上锁,在这里阻塞了10个线程,因为下面创建了10个线程,线程是同时执行的,所以在这里上一个锁,同一时段只能一个线程执行.
    NUM -=1
    time.sleep(2)
    print(NUM)
    l.release()  #解锁
lock = threading.RLock()

for i in range(10):
    t = threading.Thread(target=func,args=(lock,))
    t.start()

代码：
import threading
import time
import random
import queue #队列模块

def Producer(name,que): #生产者
    while True:
        que.put(‘包子‘) #相当于把包子放到仓库里
        print(‘%s:做了一个包子‘ %name) #打印出做了一个包子出来
        time.sleep(random.randrange(5))  #厨师5秒内做出一个包子

def Consumer(name,que): #消费者
    while True:
        try:                      #异常处理，如果碰到没有包子可吃就等待厨师做包子
            que.get_nowait()
            print(‘%s:吃了一个包子‘ %name)
        except Exception:
            print(u‘没有包子了‘)
        time.sleep(random.randrange(3)) #消费者3秒内吃掉一个包子

q = queue.Queue() #队列
p1 = threading.Thread(target=Producer,args=[‘厨师1‘,q])  #目标是Producer这个函数，args是传参
p2 = threading.Thread(target=Producer,args=[‘厨师2‘,q])
p1.start()
p2.start()

c1 = threading.Thread(target=Consumer,args=[‘张三‘,q])
c2 = threading.Thread(target=Consumer,args=[‘李四‘,q])
c1.start()
c2.start()
结果:
厨师1:做了一个包子
厨师2:做了一个包子
张三:吃了一个包子
李四:吃了一个包子
没有包子了
没有包子了
厨师1:做了一个包子
李四:吃了一个包子
没有包子了
没有包子了

代码：
import threading
import  time

def prodecer():
    print(‘厨师:等人来买包子‘) #先打印这句
    event.wait()   #打印完上一句就等待consumer线程把False变成True
    event.clear()  #然后清除状态
    print(‘厨师:有人来买包子了‘) #如果consumer把False变成True,就打印这一句

    print(‘厨师:我在给你做包子‘)  #在打印这一句
    time.sleep(5)  #停5秒钟

    print(‘厨师:包子好了，来拿吧‘)  #打印这一句的时候把False变成True，告诉另一个线程
    event.set()


def consumer():
    print(‘张三:去买个包子吃‘)
    event.set() #把False变成True告诉producer线程

    time.sleep(2)
    print(‘张三:等着包子做好‘)
    while True:
        if event.isSet():
            print(‘thanks‘)
            break
        else:
            print(‘张三:好了吗‘)
            time.sleep(1)
结果:
厨师:等人来买包子
张三:去买个包子吃
厨师:有人来买包子了
厨师:我在给你做包子
张三:等着包子做好
张三:好了吗
张三:好了吗
张三:好了吗
张三:好了吗
厨师:包子好了，来拿吧
thanks