一、程序

'''
验证线程运行速度
'''

# 调用创建线程的模块
from threading import Thread
from time import time, sleep
import threading

# 定义一种方法
def func1(name):
    print('threading:{},start'.format(name))
    sleep(3)
    print('threading:{},end'.format(name))
    sleep(3)

# 创建线程
t1 = Thread(target=func1, args=('t1',))
t2 = Thread(target=func1, args=('t2',))


if __name__=='__main__':
    print(threading.current_thread())
    start = time()
    # 开始线程
    t1.start()
    t2.start()
    #func1('t1')
    #func1('t2')
    end = time()
    t=end-start
    print(t)

二、运行结果

三、疑问

老师请问，1.我的时间为什么不换行？2._thread是以前版本的吗？3.如下图。谢谢老师解答

一、程序

'''
线程的创建与使用
线程的创建方法二：
类包装
'''
# 调用线程模块
from threading import Thread


class Mythread(Thread):
    def __init__(self, name):
        Thread.__init__(self)
        self.name = name

    def run(self):
        print('threading{0} start',format(self.name))


# 创建线程
t1 = Mythread("a")
t2 = Mythread('b')

# 启动线程
t1.start()
t2.start()

二、运行结果

三、疑问

老师请问，问题如下图，谢谢老师解答！

老师请问，这周内容是不是在pycharm也可以实现，VScode这个软件必须下载吗

老师 帮忙看看 哪里不对了  一直都是文件不存在   换了好多个路径

from socket import *
import struct
filename="微信图片_20200114223139"
server_ip="192.168.1.7"
send_data=struct.pack("!H%dsb5sb"%len(filename),1,filename.encode(),0,"octet".encode(),0)
s= socket(AF_INET,SOCK_DGRAM)
s.sendto(send_data,(server_ip,69))
f= open(filename,"ab")
while True:
    recv_data = s.recvfrom(1024)
    caozuoma,ack_num = struct.unpack("!HH",recv_data[0][:4])
    rand_port=recv_data[1][1]
    if int(caozuoma)==5:
        print("文件不存在...")
        break
    print("操作码：%d,ACK:%d,服务器随机端口：%d，数据长度：%d"%(caozuoma, ack_num,rand_port,len(recv_data[0])))
    f.write(recv_data[0][4:])#将数据写入
    if len(recv_data[0])<516:
        break
    ack_data=struct.pack("!H",4, ack_num)
    s.sendto(ack_data,(server_ip,rand_port))#回复ACK确认包

老师看下这个啥情况啊****************************

安装greenlet模块出错了

 这是什么意思

Microsoft Windows [版本 10.0.17763.195]

(c) 2018 Microsoft Corporation。保留所有权利。

(venv) C:\Users\Administrator\PycharmProjects\并发编程>pip install greenlet

Fatal error in launcher: Unable to create process using '"c:\program files (x86)\python38-32\python.exe"  "C:\Program Files (x86)\Python38-32\Scripts\pip.ex

e" install greenlet': ???????????

是不是可以这样理解,协程是有线程控制的               

import asyncio
import functools

async def compute(x,y):
    print(f'compute:{x}+{y}.....')
    await asyncio.sleep(1)
    return x+y

async def print_sum(x,y):
    # 创建task
    task = asyncio.create_task(compute(x,y)) # python3.7以上写法
    # task绑定回调函数
    task.add_done_callback(functools.partial(end,x,y)) # python3.7以上写法
    # 释放下cpu的使用
    await asyncio.sleep(1)

def end(n,m,t):
    print(f'{n}+{m}={t.result()}') # t对应传的task

if __name__ == "__main__":
    loop = asyncio.get_event_loop()
    loop.run_until_complete(print_sum(1,2))
    loop.close()

老师，我有以下几个问题，麻烦老师帮忙解答一下，谢谢！

1. 我不太清楚这块代码执行的顺序，然后debug发现结果跟直接运行的结果不一样，麻烦老师解释一下这里代码是以怎样的顺序执行的。

2. 为什么在print_sum()里面不加await asyncio.sleep(1)会报错，加了就不会报错。

3. compute()里面执行了await asyncio sleep(1)之后，不是会释放cpu吗？又靠什么代码切换到compute()执行下一行代码return x+y呢？

4. compute()的结果是怎么传给task的？

老师，多线程之间的切换需要用到多核的CPU吗?，我看笔记上写的“真正地同时执行多线程需要多核CPU 才可能实现。”，但是又说了“协程的本质是个单线程,它不能同时将单个CPU 的多个核用上,协程需要和进程配合才能运行在多CPU上”。如果多线程之间的切换要用到多核的CPU，那为什么不能让协程和线程配合？

import gevent


def gf(name):
    print(f'{name}:我想买包包！！')
    gevent.sleep(1)
    print(f'{name}:我想学编程！！')
    g2.switch()
def bf(name):
    print(f'{name} :买买买')
    gevent.sleep(1)
    print(f'{name} :一定去尚学堂')

if __name__ == '__main__':

    g1 = gevent.spawn(gf, '貂蝉')
    g2 = gevent.spawn(bf, '吕布')
    #切换任务
    g1.join()
    g2.join()

AttributeError: module 'gevent' has no attribute 'spawn'

我已经安装包了，不知道为什么还会报错

老师，我对下面代码的state变量的作用不理解，不是设置了超过3秒门自动关闭吗，为什么在门关着的时候还设置state=0呢？

from time import sleep
from threading import Thread
from threading import Event
from random import randint
def door():
    global state
    while True:
        if even.is_set():
            print('门开着，可以通行。。。')
            sleep(1)
        else:
            state = 0
            print('门关了！请刷卡！！！')
            even.wait()
        sleep(1)
        state += 1
        if state > 3:
            print('超过3秒，门自动关闭！！')
            even.clear()
def person():
    global state
    num = 1
    while True:
        if even.is_set():
            print(f'门开着呢，{num}号人进入....')
        else:
            print(f'门关着，{num}号人刷卡进入....')
            even.set()
            state = 0
        num += 1    
        sleep(randint(1,10))

if __name__ == "__main__":
    state = 0
    even = Event()
    t1 = Thread(target=door)
    t2 = Thread(target=person)
    t1.start()
    t2.start()

from multiprocessing import Pool
import os
from time import sleep
def func1(name):
    print(f"当前进程的ID:{os.getpid()},{name}")
    sleep(2)
    return name

def func2(args):
    print(args)

if __name__ == "__main__":
    pool = Pool(5)

    pool.apply_async(func = func1,args=('sxt1',),callback=func2)
    pool.apply_async(func = func1,args=('sxt2',),callback=func2)
    pool.apply_async(func = func1,args=('sxt3',),callback=func2)
    pool.apply_async(func = func1,args=('sxt4',))
    pool.apply_async(func = func1,args=('sxt5',))
    pool.apply_async(func = func1,args=('sxt6',))
    pool.apply_async(func = func1,args=('sxt7',))
    pool.apply_async(func = func1,args=('sxt8',))

    pool.close()
    pool.join()

这个代码里边为什么callback要用func2返回，为什么不和map一样直接用func1

一、代码

from threading import Thread
from queue import Queue
from time import sleep
def producer():
    num=1
    while True:
        print(f'生产了{num}号加菲猫')
        mq.put(f'生产：{num}号加菲猫')
        num+=1
        sleep(1)
def consumer():
    while True:
        print('购买了{0}'.format(mq.get()))
        sleep(2)
if __name__ == '__main__':
    # 共享数据的容器
    mq=Queue(maxsize=10)
    # 创建生产者线程
    t1=Thread(target=producer)
    # 创建消费者线程
    t2=Thread(target=consumer())
    # 创建消费者线程
    t3 = Thread(target=consumer())
    # 开始工作
    t1.start()
    t2.start()
    t3.start()

二、结果

三、问题

老师，这个程序运行后一直没显示结果，如图片所示，都是空白的，是怎么回事。等了2分钟，还是没变化

3分10秒

讲课的PPT内容，这里不应该是并行执行麽？

想问一下，多线程并发在底层是怎么实现的，内存机制是什么