老师，在实战项目开发的时候并发编程究竟怎么使用呢

老师你好，为什么在pycharm这里会出现这种情况，在vscode就可以正常显示，这个跟python版本没关系吧，我看视频中老师的版本都是3.5之后的。

from socket import *
s = socket(AF_INET, SOCK_DGRAM) #创建套接字
addr = ('192.168.1.17', 8080) #准备接收方地址
data = input("请输入：")
s.sendto(data.encode(),addr)
#发送数据时，python3需要将字符串转成byte
#encode(‘utf-8’)# 用utf-8对数据进行编码，获得bytes类型对象
#decode（）反过来
s.close()

C:\Users\pcl\venv\Scripts\python.exe "C:/Users/pcl/.1aPython all exercise/网络通信/UDP发送.py"

Traceback (most recent call last):

  File "C:\Users\pcl\.1aPython all exercise\网络通信\UDP发送.py", line 1, in <module>

    from socket import *

  File "C:\Users\pcl\.1aPython all exercise\网络通信\socket.py", line 3, in <module>

    s=socket(socket.AF_INET,socket.SOCK_STREAM)

AttributeError: partially initialized module 'socket' has no attribute 'AF_INET' (most likely due to a circular import)

Process finished with exit code 1

老师 这个为什么会报错啊

import asyncio
async def func1():  #创建协程对象
    for i in range(5):
        print('python Nb啊!!!!')
        yield from asyncio.sleep(1)
        
async def func2():
    for i in range(5):
        print('学python，还不得看pd')
        await asyncio.sleep(1)    #await 等于 yield from 就是在等待 task 结果
        
if __name__ == '__main__':
    g1 = func1()
    g2 = func2()
    # 创建事件循环
    loop = asyncio.get_event_loop()
    # 监听事件循环
    loop.run_until_complete(asyncio.gather(g1,g2))  #gather() 封装任务
    # 关闭事件循环
    loop.close()

老师我这里有报错的

然后我把yield from改成了，能运行但是会出现另一个问题

老师你好，34行的wait（）语句他可以自己单独调用的吗，还是跟23行里面的sleep(6)有关联的，程序开始运行的时候调用了ti,t2线程打印 车开走了和等车 这2句话，一起等待了6秒之后才变为True，有点没搞懂

from threading import Thread
from threading import Event
from time import sleep
'''
1.Event()可以创建一个事件管理标志，该标志(event)默认为False。
2.event.wait(timeout=None)：调用该方法的线程会被阻塞，如果设置了,
  timeout 参数，超时后，线程会停止阻塞继续执行；
'''
def car():
    #global count
    num=0
    while True:
        if even.is_set(): #判断event的标值是否为True
            print('车已经到站，可以上车')
            sleep(1)
            #count=count+1
            num=num+1
            if num % 5  == 0:
                even.clear() #将event设置为False

        else:
            print('车开走了...')
            sleep(6)
            #count=1
            even.set()  #将event设置为True

def person():
    while True:
        if even.is_set():
            print('上车')
            sleep(1)
        else:
            print('等车')
            even.wait()
            #sleep(1)

if __name__=='__main__':
    even=Event()
    #count=1
    t1=Thread(target=car)
    t2=Thread(target=person)
    t1.start()
    t2.start()

from multiprocessing import Process
from time import sleep

class Myprocess(Process):
    def __init__(self,name):#这个name就是类里面的参数
        Process.__init__(self)
        self.name=name
    def run(self):#这个self就不需要再写个namae了 因为上面有了
        print(f"Process:{self.name}start")
        
p1=Myprocess('pcl')

p1.start()

    老师 请问报错里 为什么会出现几百行的错误 我的代码都没有那么多行

C:\Users\pcl\venv\Scripts\python.exe "C:/Users/pcl/.1aPython all exercise/线程与进程/进程实现/进程类包装.py"

Traceback (most recent call last):

  File "<string>", line 1, in <module>

  File "C:\Users\pcl\lib\multiprocessing\spawn.py", line 116, in spawn_main

    exitcode = _main(fd, parent_sentinel)

  File "C:\Users\pcl\lib\multiprocessing\spawn.py", line 125, in _main

    prepare(preparation_data)

  File "C:\Users\pcl\lib\multiprocessing\spawn.py", line 236, in prepare

    _fixup_main_from_path(data['init_main_from_path'])

  File "C:\Users\pcl\lib\multiprocessing\spawn.py", line 287, in _fixup_main_from_path

    main_content = runpy.run_path(main_path,

  File "C:\Users\pcl\lib\runpy.py", line 268, in run_path

    return _run_module_code(code, init_globals, run_name,

  File "C:\Users\pcl\lib\runpy.py", line 97, in _run_module_code

    _run_code(code, mod_globals, init_globals,

  File "C:\Users\pcl\lib\runpy.py", line 87, in _run_code

    exec(code, run_globals)

  File "C:\Users\pcl\.1aPython all exercise\线程与进程\进程实现\进程类包装.py", line 13, in <module>

    p1.start()

  File "C:\Users\pcl\lib\multiprocessing\process.py", line 121, in start

    self._popen = self._Popen(self)

  File "C:\Users\pcl\lib\multiprocessing\context.py", line 224, in _Popen

    return _default_context.get_context().Process._Popen(process_obj)

  File "C:\Users\pcl\lib\multiprocessing\context.py", line 327, in _Popen

    return Popen(process_obj)

  File "C:\Users\pcl\lib\multiprocessing\popen_spawn_win32.py", line 45, in __init__

    prep_data = spawn.get_preparation_data(process_obj._name)

  File "C:\Users\pcl\lib\multiprocessing\spawn.py", line 154, in get_preparation_data

    _check_not_importing_main()

  File "C:\Users\pcl\lib\multiprocessing\spawn.py", line 134, in _check_not_importing_main

    raise RuntimeError('''

RuntimeError: 

        An attempt has been made to start a new process before the

        current process has finished its bootstrapping phase.

        This probably means that you are not using fork to start your

        child processes and you have forgotten to use the proper idiom

        in the main module:

            if __name__ == '__main__':

                freeze_support()

                ...

        The "freeze_support()" line can be omitted if the program

        is not going to be frozen to produce an executable.

Process finished with exit code 0

请问老师，我按照课程写的，这个锁为啥实现不了？

老师我这个代码输进去最后还是会显示end4

from threading import Thread
from time import sleep
class MyThread(Thread):
    def __init__(self,name):
        Thread.__init__(self)
        self.name = name
        
    def run(self):
        print(f'Threading:{self.name} start')
        sleep(3)
        print(f'Threading:{self.name} end')
        
if __name__ == '__main__':
    thread_list = []
    for i in range(5):
        t = MyThread(f't{i+1}')
        #设置当前线程为守护线程
        t.setDaemon(True)
        t.start()
        
    print('主线程结束!!!')

from threading import Thread,BoundedSemaphore
from time import sleep

def anjian(num):#num就是要传入的参数
    l.acquire()
    print(f'第{num}个人完成安检')
    sleep(2)
    l.release()

if __name__=="__main__":
    l=BoundedSemaphore(3)#里面数字就是 你设置的同时运行的线程数
    for i in range(10):
        t=Thread(target=anjian,args=(f'{i+1}',))
        t.start()

 老师 请问 为什么运行出来 格式就不整齐了

C:\Users\pcl\venv\Scripts\python.exe "C:/Users/pcl/.1aPython all exercise/线程与进程/信号量.py"

第1个人完成安检

第2个人完成安检

第3个人完成安检

第4个人完成安检

第5个人完成安检第6个人完成安检

第8个人完成安检第9个人完成安检

第7个人完成安检

第10个人完成安检

Process finished with exit code 0

老师，这个报错怎么解决，我去查了点资料，用了很多种方法，可还是不行，花点时间帮我看看

# 协程的基本使用之asyncio的task的使用
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))
    # task绑定回调函数
    task.add_done_callback(functools.partial(end,x,y))
    # 释放cpu的使用
    await asyncio.sleep(0)
    print("---------------print_num--------------")
    for i in range(1000000):
        if i%500==0:
            print(i)
            await asyncio.sleep(0.1)
def end(n,m,task):
    print(f"{n}+{m}={task.result}")

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

老师，这个回调函数理解的不是很清楚，具体应该是怎么实现的

老师，请问如果事件1执行碰到了io然后用协程，让事件1挂起并释放cpu。然后再执行事件2。有没有可能事件2也碰到了io事件1和事件2都挂起。那么这个时候在执行事件3吗？

from multiprocessing import Process,current_process
import os
from multiprocessing import Manager
def func(name,m_dict,m_list):
    print("子进程{} 获取了数据{}".format(os.getpid(),m_list))
    print("子进程{} 获取了数据{}".format(os.getpid(),m_dict))
    
    m_list.append("你好")
    m_dict["name"]="尚学堂"
   
if __name__=="__main__":
    print("主进程ID{}".format(current_process().pid))
    with Manager() as mgr:
        m_list=mgr.list()
        m_dict=mgr.dict()
        m_list.append("Hello!!!")
        
        p1=Process(target=func,args=("p1",m_list,m_dict))
        p1.start()
        p1.join()
        print(m_list)
        print(m_dict)

print('操作码：%d,ACK：%d,服务器随机端口：%d,数据长度：%d' % (caozuoma, ack_num, rand_port, len(recv_data[0])))

老师，这里的%符号没有理解，是什么意思？

老师，麻烦解答一下，我的程序没有错，第一次运行图片显示损毁，再次运行显示程序在跑，但是tftpd已经显示传输完成了，我在没有改动的前提下，关闭pycharm后再次运行就成功了，这是为什么尼，谢谢