会员可以在此提问,百战程序员老师有问必答
对大家有帮助的问答会被标记为“推荐”
看完课程过来浏览一下别人提的问题,会帮你学得更全面
截止目前,同学们一共提了 132772个问题
JAVA 全系列/第六阶段:项目管理与SSM框架/RBAC实战 37473楼

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中。

blob.png

Python 全系列/第三阶段:Python 网络与并发编程/并发编程 37474楼
JAVA 全系列/(旧的隐藏)第七阶段:JAVA 高级技术/Solr 37478楼

老师好,跟前面这位同学的问题差不多,代码基本和老师的一致:

唯一的区别就是把MyChannel 中的方法没有传参,直接在send()方法内部调用receive()方法

Channel类代码如下:

package com.sxt.chat;

import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.net.Socket;
import java.util.List;

public class MyChannel implements Runnable{
	private DataInputStream dis;
	private DataOutputStream dos;
	private boolean flag;
	public MyChannel() {
		this.flag = true;
	}
	public MyChannel(Socket socket) {
		this();
		try {
			dis = new DataInputStream(socket.getInputStream());
			dos = new DataOutputStream(socket.getOutputStream());
		} catch (IOException e) {
			this.flag = false;
			e.printStackTrace();
			CloseUtil.closeAll(dos,dis);
			
		}
	}
	
	
	public String receive() {
		String str = null;
		try {
			str = dis.readUTF();
		} catch (IOException e) {
			this.flag = false;
			e.printStackTrace();
			CloseUtil.closeAll(dis,dos);
			Server.list.remove(this);
		}
		return str;
	}
	
	
	public void send() {
		String str = receive();
		try {
			if(str != null && str.length() != 0) {
				dos.writeUTF(str);
			}
		} catch (IOException e) {
			this.flag = false;
			e.printStackTrace();
			CloseUtil.closeAll(dos,dis);
			Server.list.remove(this);
		}
	}
	
	public void sendOthers() {
//		String str = this.receive();
		List<MyChannel> others = Server.list;
		
		for (MyChannel myChannel : others) {
			if (myChannel != this) {
				myChannel.send();
			}
		}
	}
	
	@Override
	public void run() {
		while(flag) {
			sendOthers();
		}
		
	}
}


运行时报错:

image.png


如果把send改成传参 不在send内部调用receive方法,就能正常运行,


老师能帮看看是什么原因吗? 这个问题困扰我几天了

源码:

    错误版:

ChatProject2_errro.zip

    正常版:

ChatProject2.zip

两个版本就只有Channel类几行代码不同

JAVA 全系列/第二阶段:JAVA 基础深化和提高/网络编程(旧) 37480楼
Python 全系列/第一阶段:Python入门/编程基本概念 37485楼

课程分类

百战程序员微信公众号

百战程序员微信小程序

©2014-2025百战汇智(北京)科技有限公司 All Rights Reserved 北京亦庄经济开发区科创十四街 赛蒂国际工业园
网站维护:百战汇智(北京)科技有限公司
京公网安备 11011402011233号    京ICP备18060230号-3    营业执照    经营许可证:京B2-20212637