复习打卡--0821多线程并发

from threading import Thread
import time

def timer(fun):
    def wrapper(*args,**kwargs):
        time1 = time.time()
        fun(*args,**kwargs)
        time2=time.time()
        print("当前函数运行时间为:{}".format(time2-time1))
        return time2-time1
    return wrapper

def work1():
   for i in range(6):
        time.sleep(1)
        print(f‘第{i}次浇花中‘)

def work2(name):
   for i in range(5):
        time.sleep(1)
        print(f‘第{i}次{name}打墙中‘)

# 同步运行如下，需用11s多
@timer
def main():
    work1()
    work2() 

#异步运行,只用6s多
@timer
def main2():
    t1=Thread(target=work2,args=(‘musen‘,))  # 线程执行函数的传参或者 Thread(target=work2,kwargs={‘name‘:‘musen‘}) 这种方式传参

 t1.start() # 初始新线程的准备工作并执行，不一定在主线程后执行，也有可能先于主线程 print("打墙任务异步执行中") work1() main() main2()

# 定义线程类
import time
from threading import Thread

def timer(fun):
    def wrapper(*args,**kwargs):
        time1 = time.time()
        fun(*args,**kwargs)
        time2=time.time()
        print("当前函数运行时间为:{}".format(time2-time1))
        return time2-time1
    return wrapper

class MyTread(Thread):    
　　 def __init__(self):
　　　　super().__init__(*args,**keargs)
　　　　self.url=url

    def run(self):
        headers={"User-Agent": "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/75.0.3770.80 afari/537.36"}
    for i in range(100):
        #res=requests.get(‘https://www.baidu.com‘,headers=headers)
　　　　　res=requests.get(url=self.url,headers=headers)　
        print(res)

@timer
def main():
    t_list=[]
    for i in range(10):
        #t=MyTread()
　　　　　t=MyTread(‘https://www.baidu.com‘)
        t.start()
        #t.join()  如果放在这里，就会变成单线程运行，一个执行完再建一个子线程

    # 遍历所有子线程，设置子线程全部执行完后再执行主线程
    for j in t_list:
        j.join()

if __name__=="__main__":
    main()

from threading import Thread,Lock

num=0

def work1():
    global num
    for i in range(1000000):
        meta.acquire()  # 加锁
        num+=1    
        meta .release()  # 解锁

def work2():
　　 global num
    for i in range(1000000):
        meta.acquire()  # 加锁
        num+=1    
        meta .release()  # 解锁

meta=Lock()  # 创建一把锁

def main():
    t1=Thread(target=work1)
    t2=Thread(target=work2)
    t1.start()
    t2.start()
    t1.join()
    t2.join()
    print(num)

if __name__==‘__main__‘:
    main()