问题:广播通信讲完就没有一个case去演示一下吗?老师,我感觉听着还是晕乎乎的,很虚
问题:不知道为啥,我的电脑不能和飞秋进行通信。我的飞秋是2015版本的,老师指导一下吧
问题:对协程理解不好,请老师多指导,咱们用的生产者-消费者是不是一个协程的运作,请老师指导!!!!!
from multiprocessing import Pool,Manager import time import os def copy_information(source_folder,dest_folder,file): start_time = time.time() try: fr = open('H:\pythonShangxuetang/'+source_folder+'/'+file,'r',encoding='utf-8') fw = open('./'+dest_folder+'/'+file,'w',encoding='utf-8') try: print('文件%s开始复制'%file) fr_content = fr.read() fw.write(fr_content) end_time = time.time() print('文件%s复制所用时间:%d'%(file,end_time-start_time)) except Exception as e: print('文件读写错误原因是:%s'%e.args) except Exception as d: pass finally: fr.close() fw.close() def main(): count =0 #定位具体所需要复制的文件夹 folder_name = input('请输入需要复制的文件夹:') #创建新的文件夹名称 newFolderName = folder_name +'复件' os.mkdir(folder_name+'复件') #获取文件夹中的所有文本 qu = Manager().Queue() #创建queue,进程间通信 file_names = os.listdir('H:\pythonShangxuetang/'+folder_name) qu.put(file_names) #创建进程池进行多任务配合 p1 = Pool(5) # for i in file_names: while True: if not qu.empty(): p1.apply_async(copy_information,args=(folder_name,newFolderName,qu.get())) count +=1 else: break print('文件复制start') p1.close() p1.join() print('一共复制%d个文件'%count) print('文件复制end') if __name__=='__main__': main()
问题:复制不成功,逻辑思维manager.queue让进程间通信,将目录文件夹下的文件信息保存到queue中。
问题:为何这句话有时候会出现是2个,有时候会出现3个,这个线程不是同一刻发出的吗?
老师,为什么使用互斥锁之后,子线程不出错了,但是主线程还是出错呢
multiprocessing Queue q = Queue() q.put() q.put() q.put() q.put() (q.qsize()) (q.full()) (q.get()) (q.qsize())
问题:
Queue(3)限制了队列中存储消息数目为3,为什么写入4条信息的时候不报错,而程序不继续往下执行?
from multiprocessing import Manager,Pool import time def write(q): for i in "welcome": print("开始写入",i) q.put(i) def reader(q): time.sleep(3) for i in range(q.qsize): print("得到消息:",q.get()) if __name__ == "__main__": print("主进程启动") q = Manager().Queue() po = Pool() po.apply_async(write,(q,)) po.apply_async(reader,(q,)) po.close() po.join()
老师,无法收到发送的消息,修改了很多次,最后按照您的代码一模一样也试了,还是收不到发送的消息。
另一个端口可以接收到消息,也可以回复消息,但是无法自动将接收到的消息返回。
希望您解答一下哪里出了问题。谢谢。
桌面上有这个文件,路径也是对的,设置的ip也是这个 但是找不到这个文件
有点不明白程序运行的逻辑是怎么样的过程?1,这里创建类对象2,这里的功能把类对象传递给threadlocal,是不是同时也是绑定了当前线程到threadlocal?3,调用函数deal_student4,从threadlocal获取当前线程的关联性?5,是否对类对象的调用不用写?6,变量stu是否会发生混乱?局部变量?stu类对象保存在threadlocal中吗?
对于传递的问题总感觉云里雾里,希望老师能够解答疑惑。
关于字典中的内容不是很明白,为什么值是内存地址啊?
上面是老师的版本,下面是我修改的版本,
我想问的是:
1,在函数中调用其它函数,或者函数套嵌函数,那么这些函数就成为线程的私有数据了吗?
2,stu变量作为参数传递到下级函数中,也就是stu变量,不受线程影响了,在各自线程中独立存在?
3,stu=Student(name)是创建类对象,fun1(stu)是调用函数fun1,那么Student也被调用了吗?不明白这里是怎么回事啊?
请问老师这里客户端发给服务器的第一个包里的ACK = y+1是啥意思,为啥要在这里方式送一个ACK确认包?
from socket import * a = socket(AF_INET,SOCK_DGRAM) #创建套字节、为固定句式 address = ("192.168.10.40",8080) date = input("输入发送内容:") a.sendto(date.encode('GB2312'),address) #接收数据 redate = a.recvfrom(1024) #括号内为最大字节数 print(redate[0].decode("GB2312")) a.close()
为什么调试助手接收端还是没转化过来啊
非常抱歉给您带来不好的体验!为了更深入的了解您的学习情况以及遇到的问题,您可以直接拨打投诉热线:
我们将在第一时间处理好您的问题!
关于
课程分类
百战程序员微信公众号
百战程序员微信小程序
©2014-2025百战汇智(北京)科技有限公司 All Rights Reserved 北京亦庄经济开发区科创十四街 赛蒂国际工业园网站维护:百战汇智(北京)科技有限公司 京公网安备 11011402011233号 京ICP备18060230号-3 营业执照 经营许可证:京B2-20212637