复制一个文件夹里的文件到另一个目录下(使用多线程的方法实现)

0 阅读 作者:哈哈哈_3 2017-10-18

今天是很特殊的日子,是3月21号,是我们传统的诺鲁孜节,又是我跟女朋友恋爱的半年纪念日。我很想放松放松,但是我不能,虽然没有正式开始实习,但是我得好好利用一个星期能来公司的两天好机会好好努力,要从现在开始养成好习惯,已过不管从事什么工作,首先态度要认真。所以早上一大早我来了公司完成了两个星期以来一直没有完成的任务,在经理的指导下,找到问题所在,有所突破,成功的完成任务,所以打算下午请个假,回学校跟朋友们玩,庆祝我和女朋友的“半年”,哈哈哈!!!!!!!!!
参考网站http://blog.csdn.net/etzmico/article/details/7786525/

我发这个文章的主要目的是为了永久性保存我的这个小小成功,代码保存好,以后有需要拿来用,顺便跟大家分享,有什么问题可以指出来,相互学习···········
多线程确实太复杂了,还得努力学习。还有下面的这个处理方法太奇妙。
/*// 尝试3次
int test = 5;
while (test > 0) { //这个循环非常巧妙,在经理的提示下完才完成,这个方法必须学会

        File[] dir = manager.getFirstDirectory();

        if (dir != null) {
            processDirectory(dir);

            test = 5;
        } else {

            try {
                Thread.sleep(1000);
            } catch (InterruptedException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }

            test--;

        }
    }

*/

import java.io.File;
import java.lang.reflect.Array;
import java.util.LinkedList;
import java.util.Queue;

public class DirManager {

private Queue<File> queue = new LinkedList<File>(); // 放文件夹的队列

private String copy_From = "E:\\amu1"; // 源文件

public DirManager(){

    queue.add(new File(copy_From));

}

public void add1(File dir){

     queue.add(dir);

     System.out.println(queue.size());

}

synchronized public File[] getFirstDirectory() {
    if (!queue.isEmpty()) {
        File dir = queue.poll();// 如果队列不空,返回队列中的头文件
        File [] get=(new File(dir.getAbsolutePath())).listFiles();
        return get;
    } else
        return null;
}

}

import java.io.BufferedInputStream;
import java.io.BufferedOutputStream;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.IOException;

public class Worker extends Thread {

private DirManager manager;
// private String copy_From = "E:\\amu1"; // 源文件

private String copy_TO = "E:\\amu2"; // 目标文件

public Worker(DirManager m) {
    manager = m;
}

public void run() {

    //System.out.println(11);

    // 尝试3次
    int test = 5;
    while (test > 0) {   //这个循环非常巧妙,在经理的提示下完才完成,这个方法必须学会

        File[] dir = manager.getFirstDirectory();

        if (dir != null) {
            processDirectory(dir);

            test = 5;
        } else {

            try {
                Thread.sleep(1000);
            } catch (InterruptedException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }

            test--;

        }
    }

}

private void processDirectory(File[] dir) {

    //File [] get_From2=(new File(dir.getAbsolutePath()).listFiles();
    for(int i=0;i<dir.length;i++){

                    if (dir[i].isFile()) {

                        String toFile = copy_TO + "/" + dir[i].getName(); // 写的时候这里少了个/.导致不能复制
                        try {
                            copyFile(dir[i], new File(toFile));
                        } catch (IOException e) {
                            // TODO Auto-generated catch block
                            e.printStackTrace();
                        }

                    }
                    if (dir[i].isDirectory()) {
                        manager.add1(dir[i]);
                    }
    }

}

private void copyFile(File from_File, File to_File) throws IOException {
    // TODO Auto-generated method stub

    FileInputStream infile = new FileInputStream(from_File);// 新建输入流
    BufferedInputStream inbuf = new BufferedInputStream(infile);// 对输入流进行缓冲

    FileOutputStream outfile = new FileOutputStream(to_File); // 新建输出流
    BufferedOutputStream outbuf = new BufferedOutputStream(outfile);// 对输出流进行缓冲

    // 缓冲数组
    byte[] bt = new byte[20 * 1024 * 1024];
    int len;
    while ((len = inbuf.read(bt)) != -1) {

        outbuf.write(bt, 0, len);

    }

    outbuf.flush(); // 刷新缓冲

    infile.close();
    inbuf.close();

    outfile.close();
    outbuf.close();
}

}

public class Main{

public static void main(String[] args) {

    DirManager dirManager = new DirManager();

    for (int i = 0; i <10; i++) {     

        Worker worker = new Worker(dirManager);
        worker.start();

    }

}

}

相关标签: JAVA Android
原文地址:http://www.imooc.com/article/5731
广告一下
热门教程
PHP7报A non well formed numeric value encountered 0
Linux系统下关闭mongodb的几种命令分享 0
mongodb删除数据、删除集合、删除数据库的命令 0
Git&Github极速入门与攻坚实战课程 0
python爬虫教程使用Django和scrapy实现 0
libnetsnmpmibs.so.31: cannot open shared object file 0
数据结构和算法视频教程 0
redis的hash结构怎么删除数据呢? 0
C++和LUA解析器的数据交互实战视频 0
mongodb errmsg" : "too many users are authenticated 0
C++基础入门视频教程 0
用30个小时精通C++视频教程可能吗? 0
C++分布式多线程游戏服务器开发视频教程socket tcp boost库 0
C++培训教程就业班教程 0
layui的util工具格式时间戳为字符串 0
C++实战教程之远程桌面远程控制实战 1
网络安全培训视频教程 0
LINUX_C++软件工程师视频教程高级项目实战 0
C++高级数据结构与算法视频教程 0
跨域问题很头疼?通过配置nginx轻松解决ajax跨域问题 0
相关文章
【译】JavaScript数据结构(3):单向链表与双向链表 16
10个JavaScript难点 16
【译】苹果拒绝支持PWA,有损Web的未来 16
iView 一周年了,同时发布了 2.0 正式版,但这只是开始... 16
nodejs+mongodb构建一个简单登录注册功能 16
【译】JavaScript数据结构(4):树 16
组件化开发与黑箱 16
TypeScript - 不止稳,而且快 16
webpack3+anujs+ReactCSSTransitionGroup 16
原生js实现图片放大镜效果 16
WEB缓存探究第二弹——实战 16
纯笔记:vfork 的一些使用场景(顺便讲一下 fork 的原理) 16
Android APP 内部捐赠实现(支付宝&amp;微信) 16
WKWebView 的一些小总结 16
模型评价(一) AUC大法 16
开始使用GraphQL 16
Webpack模块化原理简析 16
gulp使用问题记录 16
使用Angular4动画为页面添彩 16
Python27 Matplotlib (win64 python2.7) 安装及简单使用 16