老师，从这节开始怎么没文档了

为什么直接把函数体recv_data()和send_data()传入Thread里面,可以连接成功，但是为什么无法交互

Traceback (most recent call last):

  File "C:\Users\18785\PycharmProjects\pythonProject1\venv\tcp客户端发送信息案例.py", line 4, in <module>

    client_socket.connect(("127.0.0.1",8899))

ConnectionRefusedError: [WinError 10061] 由于目标计算机积极拒绝，无法连接。

老师，这是咋了么？

为什么没有打印p=MyRocess("p")

time sleep
multiprocessing Process
os

MyProcess(Process):
    (,name):
        Process.()
        .name=name

    ():
        (.name,os.getpid())
        (.name,os.getcwd())



__name__ == :

    (,os.getpid())
    p = MyProcess()
    p1 = MyProcess()
    p.start()
    p1.start()

我这个代码运行后只运行了

 print(f"当前ID：",os.getpid())

其他的跟没有调用一样。是python或pychram版本的问题？

socket *
threading Thread

():
    :
        redata = udp_socket.recvfrom()
        recv_content = recv_data[].decode()
        (recv_contentredata[])
        recv_content == :
           ()
           ():
    addr = (, )
    :
        data = ()
        udp_socket.sendto(data.encode(), addr)
        data == :
            ()
            __name__==:
    udp_socket = socket(AF_INET, SOCK_DGRAM)
    udp_socket.bind((, ))
    t1 = Thread(=send_data)
    t2 = Thread(=recv_data)
    t2.start()
    t1.start()
    t1.join()
    t2.join()

运行上述代码后报错：
输入信息：Exception in thread Thread-2 (recv_data):
Traceback (most recent call last):
  File "C:\Program Files\Python311\Lib\threading.py", line 1045, in _bootstrap_inner
    self.run()
  File "C:\Program Files\Python311\Lib\threading.py", line 982, in run
    self._target(*self._args, **self._kwargs)
  File "D:\Study\PythonBigData\mypro1\UDP客户端1.py", line 8, in recv_data
    redata = udp_socket.recvfrom(1024)
             ^^^^^^^^^^^^^^^^^^^^^^^^^
ConnectionResetError: [WinError 10054] 远程主机强迫关闭了一个现有的连接。

请问是出了什么问题？

if __name__ == '__main__':
    # 创建进程列表
    t_list = []
    mq = Queue()
    mq.put('1')
    mq.put('2')
    mq.put('3')
    # 循环创建进程
    for i in range(3):
        t = MyProcess('p{}'.format(i), mq)
        t.start()
        t_list.append(t)
    # 等待进程结束
    for t in t_list:
        t.join()
    print(mq.get())
    print(mq.get())
    print(mq.get())

老师您好，请问，上面这段代码为什么要写两个for循环？不是很理解。第一个for循环运行了三个进程，然后第二个for循环依次等待三个进程？我不理解的是，第一个for循环是否会将三个进程都运行完，然后再执行第二个for循环，依次等待?如果是这样，第一个for循环运行后，三个进程都运行了，还要第二个for循环有什么意义？ 如果稍作修改代码，如下，会有何问题？

if __name__ == '__main__':
    # 创建进程列表
    t_list = []
    mq = Queue()
    mq.put('1')
    mq.put('2')
    mq.put('3')
    # 循环创建进程
    for i in range(3):
        t = MyProcess('p{}'.format(i), mq)
        t.start()
        t_list.append(t)
        t.join()
    print(mq.get())
    print(mq.get())
    print(mq.get())

def producer():
    num = 1
    if num < 10:
        if queue.qsize() < 10:
            print(f'生产:{num}号，大馒头')
            queue.put(f'大馒头：{num}号')
            num += 1
    else:
        print('馒头框满了,等待来人消费啊！')
    sleep(1)

def consumer():
    if queue.qsize() > 0:
        print(f'获取馒头：{queue.get()}')
        sleep(1)
    else:
        print('没有馒头了！')


if __name__ == '__main__':
    queue = Queue()
    t = Thread(target=producer)
    t.start()
    c = Thread(target=consumer)
    c.start()

老师，我自己写的代码，但是始终都只能生产一个馒头并获取一个馒头。请问问题出在哪里？谢谢！

便利  for i in range （3）这是干嘛了

孩子有点懵

老师想请教下，Process类不是有了name属性吗，为什么继承了Process类还要再加一个name属性呢

 我ipconfig之后有很多的ip我使用tcp，utp应该连接的是哪个ip？

socket *
threading Thread


():
    :
        recv_data = s.recvfrom()recv_content = recv_data[].decode()
        (recv_data[].decode()recv_data[])
        recv_content == :
            ()
            ():
    addr = (, )
    :
        data = ()
        s.sendto(data.encode(), addr)
        data == :
            ()
            __name__ == :
    s = socket(AF_INET,SOCK_DGRAM)s.bind((,))t1 = Thread(=recv_data())
    t2 = Thread(=send_data())
    t1.start()
    t2.start()
    t1.join()
    t2.join()

socket *
threading Thread


():
    :
        recv_data = s.recvfrom()recv_content = recv_data[].decode()
        (recv_data[].decode()recv_data[])
        recv_content == :
            ()
            ():
    addr = (, )
    :
        data = ()
        s.sendto(data.encode(), addr)
        data == :
            ()
            __name__ == :
    s = socket(AF_INET,SOCK_DGRAM)s.bind((,))t1 = Thread(=recv_data())
    t2 = Thread(=send_data())
    t1.start()
    t2.start()
    t1.join()
    t2.join()
    s.close
两个代码都运行没有结果

为什么1还没出来2就进去了

老师 tcp怎么没笔记