老师，错误显示没有这个属性，我应该怎么弄？

老师您好：

     请问queue模块是python3.X版本的吗？我用的是arcgis软件集成的python2.7.14，因为要用到里面的arcpy。

from threading import  RLock

def fun1():
    lock.acquire()
    print("fun1 ")
    fun2()
    lock.release()

def fun2():
    lock.acquire()
    print("%%%%%%%")

    lock.acquire()
    print("fun2")

    fun1()
    lock.release()

def fun3():
    print('####')
    fun1()
    fun2()

if __name__ == '__main__':

    lock = RLock()
    fun3()
    
    #老师好 为什么我这里他会报错呢

from multiprocessing import Process,Pipe
import os

def fun1(name,con):
    print(f"当前进程号为{os.getpid()}接受的数据为{con.recv()}")
    con.send("nihao")
if __name__ == '__main__':

    print(f"著京城{os.getpid()}")
    con1, con2 = Pipe()
    p1=Process(target=fun1,args=("p1",con1))
    con2.send("hello")

    p1.join()
    print(con2.recv())
    
    #老师 这是哪部分出了问题

import struct
from socket import *
filename = "DJTT.jpg"
server_ip = '192.168.1.9'
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')  #  a 以追加模式打开（必要时可以创建）b:二进制
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:])     #数据的第一部分中再去掉操作码和块编号的4个字节 则内容为[4:]
    if len(recv_data)<516:

        break
    #发送确认包给服务器告知接受成功
    ack_data = struct.pack("!HH",4,ack_num)   # !HH 格式占用4个字节，操作码为4 确认包 ，块编号
    #回复ACK确认包
    s.sendto(ack_data,(server_ip,rand_port))

老师 这是什么情况 我用 课件的源码运行也是报这样的错，有空帮我看看谢谢

.

老师，请问视频中炒西兰花，红烧肉的死锁代码，如果用类去写应该怎么写

这个问题哪了？

#他不可以fun2中在去调用fun1吗 为什么呢 老师

协程通俗点讲是不是每个工人各自完成各自的任务，同时进行？

老师执行fun1时，会调用fun2。是在fun1的基础上运行fun2函数吗？线程里边的程序是交替进行的是吗？不再单纯的自上而下

老师，我想完成两个聊天室的实时聊天：

聊天室1的代码如下：

from socket import *
import time
#1创建套接字
udpSocket = socket(AF_INET, SOCK_DGRAM)
bindAddr = ("",7088)
udpSocket.bind(bindAddr)#绑定
data = input("请输入：")
udpSocket.sendto(data.encode("gb2312"),("",8080))
while True:
    #接收对方发送的数据
    recvData = udpSocket.recvfrom(1024)
    print('【%s】 %s.%s' %(time.ctime(),recvData[1],recvData[0].decode("GB2312")))
    a = input("请输入：")
    udpSocket.sendto(a.encode('GB2312'),recvData[1])
#5关闭套接字
udpSocket.close()

聊天室2的代码如下：

from socket import *
import time
#1创建套接字
udpSocket = socket(AF_INET, SOCK_DGRAM)
bindAddr = ("",8080)
udpSocket.bind(bindAddr)#绑定
while True:
    #接收对方发送的数据
    recvData = udpSocket.recvfrom(1024)
    print('【%s】 %s.%s' %(time.ctime(),recvData[1],recvData[0].decode("GB2312")))
    a = input("请输入：")
    udpSocket.sendto(a.encode('GB2312'),recvData[1])
#5关闭套接字
udpSocket.close()

始终会报错，麻烦您帮我看一下

代码1

from socket import *
from threading import Thread
s=socket(AF_INET,SOCK_DGRAM)
def fasong():
    while True:
        data = input("请输入内容:")
        s.sendto(data.encode(), ("192.168.1.8", 8080))
def jieshou():
    while True:
        s.bind(("",8585))
        recvdata=s.recvfrom(1024)
        print(recvdata[0].decode())
t1=Thread(target=fasong)
t2=Thread(target=jieshou)
t1.start()
t2.start()

代码2:

from socket import *
from threading import Thread
s=socket(AF_INET,SOCK_DGRAM)
def fasong():
    while True:
        data=input("请输入内容:")
        s.sendto(data.encode(),("192.168.1.8",8585))
def jieshou():
    while True:
        s.bind(("",8080))
        recvdata=s.recvfrom(1024)
        print(recvdata[0].decode())
t1=Thread(target=fasong)
t2=Thread(target=jieshou)
t1.start()
t2.start()

运行结果:

问题:

老师请问一下，我这里使用全双工实现聊天室，开辟了两个线程，可为什么会出现这个错误，而且每次只能输入发送内容，不能接收，好像用来接收数据的t2线程没有用上，一直没有数据接收到，请问老师这个是什么原因?

老师 关于这个协程  视频中老师讲的遇到IO就会停止运行 或者切换到下一个任务 这个IO是指什么

老师，请问一下为啥会这样的T.T,我重新运行好几次都不行

老师，问下，课程中的py文件是不是也可以理解为一个模块，主要是看调用方有没有按照线程的方式调用