使用多线程以及RandomAccessfile来实现多线程复制文件

2023-05-16

Class RandomAccessFile 介绍

  • 该类的实例支持读取和写入随机访问文件。 随机访问文件的行为类似于存储在文件系统中的大量字节。 有一种游标,或索引到隐含的数组,称为文件指针 ; 输入操作读取从文件指针开始的字节,并使文件指针超过读取的字节。 如果在读/写模式下创建随机访问文件,则输出操作也可用; 输出操作从文件指针开始写入字节,并将文件指针提前到写入的字节。 写入隐式数组的当前端的输出操作会导致扩展数组。 文件指针可以通过读取getFilePointer方法和由设置seek方法。
  • 在这个类中的所有读取例程通常都是如果在读取所需的字节数之前到达文件结尾,则抛出一个EOFException (这是一种IOException )。 如果任何字节由于除文件末尾之外的任何原因而无法读取,则抛出IOException以外的EOFException 。 特别地,如果流已经被关闭,则可以抛出IOException

方法摘要:

StringreadUTF()
从该文件读取字符串。
voidseek(long pos)
设置文件指针偏移,从该文件的开头测量,发生下一次读取或写入。
voidsetLength(long newLength)
设置此文件的长度。
intskipBytes(int n)
尝试跳过 n字节的输入丢弃跳过的字节。
voidwrite(byte[] b)
从指定的字节数组写入 b.length个字节到该文件,从当前文件指针开始。
voidwrite(byte[] b, int off, int len)
从指定的字节数组写入 len个字节,从偏移量 off开始写入此文件。  

代码示例:

  1 package com.edu.testThreadDlFile;
  2 
  3 import java.io.File;
  4 import java.io.FileNotFoundException;
  5 import java.io.IOException;
  6 import java.io.RandomAccessFile;
  7 import java.util.concurrent.TimeUnit;
  8 
  9 /**
 10  * @作者 five-five
 11  * @创建时间 2020/10/15
 12  */
 13 public class DownloadUtil {
 14     private File fromFile;//源文件
 15     private File toFile;//要拷贝到的地方
 16     private int threadNum;//线程数量
 17 
 18     //下载的方法
 19     public void doDownLoad() {
 20         System.out.println(fromFile.length());
 21         for (int i=0;i<threadNum;i++){
 22             MydownLoadThread thread = new MydownLoadThread(i);
 23             thread.setName("线程"+(i+1));
 24             System.out.println(thread.getName()+"的任务量是\t"+thread.getBlockSize());
 25             thread.start();
 26         }
 27         System.out.println("文件上传完毕");
 28     }
 29 
 30     public DownloadUtil() {
 31     }
 32 
 33     public DownloadUtil(File fromFile, File toFile, int threadNum) {
 34         this.fromFile = fromFile;
 35         this.toFile = toFile;
 36         this.threadNum = threadNum;
 37     }
 38 
 39     class MydownLoadThread extends Thread {
 40 
 41         private volatile int index;//表示第几个线程
 42         private long blockSize = fromFile.length() % threadNum == 0
 43                 ? fromFile.length() / threadNum
 44                 : fromFile.length() / threadNum + (fromFile.length() % threadNum); //每个线程下载的文件大小
 45         private volatile long startPos;//起始位置
 46 
 47         /**
 48          * 第多少个线程
 49          *
 50          * @param index
 51          */
 52         public MydownLoadThread(int index) {
 53             this.index = index;
 54             startPos = index * blockSize;//计算下载了多少
 55         }
 56 
 57         @Override
 58         public void run() {
 59             RandomAccessFile rf = null;
 60             RandomAccessFile wf = null;
 61             try {
 62 //                System.out.println("起始位置"+startPos);
 63                 //"r", "rw", "rws", or "rwd"
 64                 rf = new RandomAccessFile(fromFile, "r");//只读
 65                 wf = new RandomAccessFile(toFile, "rw");//只写
 66                 rf.seek(startPos);
 67                 wf.seek(startPos);
 68                 byte[] buf = new byte[1024 * 1024];//缓存区为1MB
 69                 int len = -1;
 70                 do {
 71                     //记录每次读取的大小(缓冲区可能大于线程任务量)
 72                     len = blockSize > buf.length ? buf.length : (int) blockSize;
 73                     //io操作
 74                     rf.read(buf, 0, len);
 75                     wf.write(buf, 0, len);
 76                     blockSize -= len;
 77                     System.out.println(Thread.currentThread().getName() + "读取了" + len + "个字节");
 78                 } while (blockSize>0);
 79                 wf.close();
 80                 rf.close();
 81 //                TimeUnit.SECONDS.sleep(1);//每次睡一秒
 82             } catch (Exception e) {
 83                 e.printStackTrace();
 84             }
 85         }
 86 
 87         public int getIndex() {
 88             return index;
 89         }
 90 
 91         public void setIndex(int index) {
 92             this.index = index;
 93         }
 94 
 95         public long getBlockSize() {
 96             return blockSize;
 97         }
 98 
 99         public void setBlockSize(long blockSize) {
100             this.blockSize = blockSize;
101         }
102 
103         public long getStartPos() {
104             return startPos;
105         }
106 
107         public void setStartPos(long startPos) {
108             this.startPos = startPos;
109         }
110     }
111 
112     public File getFromFile() {
113         return fromFile;
114     }
115 
116     public void setFromFile(File fromFile) {
117         this.fromFile = fromFile;
118     }
119 
120     public File getToFile() {
121         return toFile;
122     }
123 
124     public void setToFile(File toFile) {
125         this.toFile = toFile;
126     }
127 
128     public int getThreadNum() {
129         return threadNum;
130     }
131 
132     public void setThreadNum(int threadNum) {
133         this.threadNum = threadNum;
134     }
135 }
DownloadUtil
 1 package com.edu.testThreadDlFile;
 2 
 3 import java.io.File;
 4 
 5 /**
 6  *
 7  * @作者 five-five
 8  * @创建时间 2020/10/15
 9  */
10 public class TestRandomAccessFile {
11     public static void main(String[] args) throws Exception {
12         File from=new File("D:\\图片\\Saved Pictures\\图片\\街道.jpg");
13         File to=new File("C:\\Users\\15713\\Desktop\\新建文件夹\\"+from.getName());
14         DownloadUtil downloadUtil = new DownloadUtil(from,to,8);
15         downloadUtil.doDownLoad();
16     }
17 }
测试代码

控制台截图:

本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)

使用多线程以及RandomAccessfile来实现多线程复制文件 的相关文章

  • Redis(4)——主从复制

    Redis主从复制 主从复制 xff1a 指的是将一个Redis服务器的数据 xff0c 复制到其他的Redis服务器 前者称为主节点 xff08 master leader xff0c 后者称为从节点 xff08 slave follow
  • Redis(5)——缓存穿透和雪崩

    概要 Redis缓存的使用 xff0c 极大的提高了应用程序的性能和效率 xff0c 特别是数据查询等 但同时 xff0c 它也带来了一些问题 其中 xff0c 最主要的问题就是数据一致性 xff0c 从严格意义上来讲 xff0c 这个问题
  • 复习:结构体大小的内存对齐问题

    内存对齐 内存对齐是指 xff1a 任意单个类型的数据都需要存放在能被它本身大小所能整除的地址上 基本类型的大小 char 1 short 2 int 4 long 4 long long 8 float 4 double 8 指针 4 8
  • 0.一些自己初学Solidworks的疑惑

    1 为什么要选择学习SolidWorks 首先 作为初学者 我们对一个东西并不是很了解 那么就需要别人来教我们 对吧 这些人可以是老师 可以是同学 可以是师傅 可以是网络上热心肠的大神 可以是一些培训机构 等等 首先呢 学习三维设计软件 看
  • LInux——五种IO模型

    Linux中的IO简述 IO主要分为以下的三种 xff1a 内存IO网络IO磁盘IO 通常我们所说的IO是后两者 xff0c Linux中无法直接操作IO设备 xff0c 必须通过系统调用请求kernal来协助完成IO的动作 xff0c 内
  • 复习:Linux中的软连接和硬连接

    前言 首先我们先来复习以下Linux的文件系统 Linux的文件系统是EXT4 以EXT4文件系统格式化磁盘时 xff0c 将磁盘分成了三个区 xff0c 分别是 xff1a 1 superblock xff1a 记录文件系统的整体信息 x
  • 复习:字节对齐的原则

    为什么需要字节对齐 xff1f 现代计算机中内存空间都是按照byte划分的 xff0c 从理论上讲似乎对任何类型的变量的访问可以从任何地址开始 xff0c 但实际情况是在访问特定类型变量的时候经常在特定的内存地址访问 xff0c 这就需要各
  • Reactor模型

    前言 首先让我们来回顾一下select poll和epoll是如何获取网络事件的 xff1a 在获取事件时 xff0c 先把我们要关心的连接传给内核 xff0c 再由内核检测 xff1a 若没有事件发生 xff0c 线程只需阻塞在这个系统调
  • Proactor模型

    前言 上一篇讲解的Reaactor是非阻塞的同步网络模式 xff0c 而Proactor是异步网络模式 至于异步IO怎么理解 xff1a 可以参考我的这一篇博客 xff1a Linux的五种IO模型 理解之后 xff1a 你就会感受到 xf
  • STL空间配置器(一级配置器及二级配置器)

    前言 在我们日常使用STL中的容器时 xff0c 我们是几乎感受不到空间配置器的存在 xff0c 因为他一直在默默工作 xff0c 我们在之前的这一篇博客中也大概介绍过 xff1a C 43 43 xff08 21 xff09 vector
  • HTTP各个版本的区别

    HTTP 1 0 短连接版本 HTTP 1 0规定浏览器与服务器只保持短暂的连接 xff0c 即每一次请求都需要与服务器建立一次TCP连接 xff0c 服务器完成请求处理后立即断开TCP连接 服务器不会跟踪每个客户也不记录过去的请求 xff
  • 实时时钟芯片DS1307的使用及驱动代码

    DS1307实时时钟芯片的介绍及驱动代码 目录 一 DS1307是什么 xff1f 二 DS1307的功能 三 DS1307的寄存器 四 代码 1 读出数据 2 写入数据 3 时间初始化设置 4 获取当前时间 五 注意事项 总结 一 DS1
  • 单片机测量NTC热敏电阻温度的方法(含程序代码)

    1 NTC介绍 NTC是负温度系数热敏电阻 xff0c 随着温度的升高 xff0c NTC的阻值会呈非线性的下降 2 硬件连接 这里采用100k 3950的热敏电阻 xff0c 100k代表的是在25 下的标准阻值 xff0c 3950是热
  • 代码编写规范

    目录 1 头文件 2 函数 3 标识符命名与定义 3 1 通用命名规则 3 2 文件命名规则 3 3 变量命名规则 3 4 函数命名规则 3 5 宏的命名规则 4 变量 5 宏 常量 6 质量保证 7 程序效率 8 注释 9 排版与格式 1
  • 1.SolidWorks各模块的学习顺序

    1 草图模块 nbsp nbsp nbsp nbsp nbsp nbsp nbsp nbsp 草图就是用线段画出零件的某一个视角的轮廓 草图是下面功能的基础 因为零件的三维建模 其实就是先画出草图 然后再通过拉伸 旋转 扫描 切除等命令生成
  • parser用法

    parser用法 导入库示例化添加参数解析参数设置属性 导入库 span class token keyword import span argparse 示例化 parser span class token operator 61 sp

随机推荐

  • roslaunch realsense2_camera rs_camera.launch和sudo apt-get install ros-melodic-rgbd-launch报错

    roslaunch realsense2 camera rs camera launch和roslaunch realsense2 camera rs rgbd launch报错 具体报错信息 roslaunch realsense2 ca
  • 如何设置cmake将外部文件作为资源添加到工作目录

    https stackoverflow com questions 46995733 how to set cmake in order to add txt files into working directory as resource
  • string、char*和char[]的转换

    char 和const char 的转换 const char 转 char xff08 1 xff09 为什么不能直接赋值 xff1f 这里你可以这么想 xff0c 假如const char类型字符串可以赋值给char类型 xff0c 那
  • 11-串口通信

    微控制器与外部设备的数据通信 xff0c 分为并行通信和串行通信 并行 xff1a 数据的各位同时发送或接受 xff0c 每个数据位使用一条导线 串行 xff1a 数据一位接一位地顺序发送或接收 串行通信有SPI IIC UART多种 xf
  • C语言编程规范设置 (vscode设置)

    1 打开vscode设置后 2 搜索format 3 把以下选项打上对勾 Editor Format On Paste Editor Format On Save Editor Format On Type 4 C Cpp 这一选项选择以下
  • c++ vscode 环境一键配置

    致谢 首先感谢原作者为我等初学者所做的软件 xff0c 其他文章讲了一堆的东西都没解决 xff0c 作者一个软件一步到位 xff0c 如果觉得不错的话可以star一下 xff0c 原作者视频地址 xff1a https www bilibi
  • 使用ESP8266实现单片机与上位机之间的wifi通信。

    使用ESP8266实现单片机与上位机之间的wifi通信 首先弄清楚8266的工作模式 xff0c 分别是 模式1 xff1a station xff0c 模式2 xff1a ap xff0c 模式3 xff1a station 43 ap
  • 【C 陷阱与缺陷】(四)连接

    码字不易 xff0c 对你有帮助 点赞 转发 关注 支持一下作者 微信搜公众号 xff1a 不会编程的程序圆 看更多干货 xff0c 获取第一时间更新 代码 xff0c 练习上传至 xff1a https github com hairrr
  • DIY无人机(匿名拓控者P2+F330机架)

    今年三月份的时候DIY过一个大疆NAZA 43 F450机架的无人机 xff0c 第一次体验DIY多旋翼无人机的全流程 xff0c 目的其实是为了后面更深入了解做准备 不然的话 xff0c 这钱买个大疆MINI3不香吗 xff1f DIY无
  • 在lammps模拟过程中的常用势函数设置

    文章目录 1 lj cut1 1 lj cut在in文件中使用方法1 2 lj cut在data文件中使用方法1 3 lj cut参数查询方法1 4 lj cut参数单位转换方法1 5 lj cut不同原子之间的参数1 6 lj cut参数
  • C语言十进制转16进制

    int DEC HEX uint32 t Dec int ram 61 0 整 int ray 61 0 余 uint32 t Hex 61 0x0 int i 61 0 do ram 61 Dec 16 ray 61 Dec 16 Dec
  • Windows系统下的Visual studio2019 安装 opencv4.5.1的安装

    OpenCV文档 xff1a https docs opencv org 4 5 1 examples html 安装OpenCV 4 5 1 xff0c 下载地址 https opencv org releases 下载完成后得到open
  • STM32串口初始化与使用详解(基于HAL库编程)

    STM32串口初始化与使用详解 串口简介串口初始化具体步骤串口收发理论代码执行 串口简介 USART Universal Synchronous Asynchronous Receiver Transmitter 通用同步 异步串行接收发送
  • STM32F103C8T6+OV7670(有FIFO和无FIFO版本)入门教程/使用总结(待续写,有问题可发在评论区中)

    前言 xff1a 本文为第一遍草稿 xff0c 错误会有点多 xff08 指技术性的东西会叫错等等 xff0c 欢迎纠正 xff09 xff0c 有需要可以先看看 OV7670还没有完全弄清楚 xff0c 目前已成功出图 xff08 指测试
  • 串口DMA实现接收--不定长度接收

    1 DMA接收配置 1 direction xff1a 数据传输的方向是外设 xff08 串口 xff09 gt 内存 xff08 DMA Buff xff09 xff1b 2 memory inc xff1a 内存自增 xff0c 内存指
  • ROS信息的收发

    图像信息的收发 图像信息发送 include lt ros ros h gt include lt image transport image transport h gt 用于image的订阅和发布 xff0c 并为压缩模式compres
  • 标定工具Kalibr安装、使用及标定结果评估方法

    单目相机标定 安装和配置 cd kalibr workspace source devel setup bash 如果使用april tag标定板 xff0c 设置aprilgrid yaml配置文件 标定数据bag采集 采集单目标定数据时
  • 2.什么是机械设计?

    机械设计是研究如何创造机械 以使其安全 可靠地工作等的内容 机械的定义是 一个组装的零件系统 可以以预定和受控的方式传递运动和能量 或更简单地说 一个控制力和运动的系统 那么 设计是又是什么呢 设计 设 计 设就是设想 从无到有的想象 想象
  • 手把手教你实现一个单链表

    目录 一 节点声明二 尾插三 链表打印四 头插五 尾删六 头删七 查找值八 指定插入九 指定删除十 销毁链表 一 节点声明 链表是一种数据结构 xff0c 用于数据的存储 如图 xff0c 每一个链表节点所在的内存空间是不延续的 xff0c
  • 使用多线程以及RandomAccessfile来实现多线程复制文件

    Class RandomAccessFile 介绍 该类的实例支持读取和写入随机访问文件 随机访问文件的行为类似于存储在文件系统中的大量字节 有一种游标 xff0c 或索引到隐含的数组 xff0c 称为文件指针 输入操作读取从文件指针开始的