Java-->多線程複製(文件指針)

来源:http://www.cnblogs.com/xmcx1995/archive/2016/08/18/5785177.html
-Advertisement-
Play Games

--> 這裡用到兩種方法...其實也不算兩種,就一點點不一樣而已... > Test 測試類 --> MyThread類即線程實現類 --> 邪惡的分割線 --> Test測試 --> MyThread線程實現類 --> 感覺第二種也完全是多餘的啊,就是一種方法... ...


--> 這裡用到兩種方法...其實也不算兩種,就一點點不一樣而已...

---> Test 測試類

package com.dragon.java.multithreadcopy;

import java.io.File;
import java.util.Scanner;

/*
 * 利用多線程複製文件1
 */
public class Test {
    public static void main(String[] args) {
        @SuppressWarnings("resource")
        Scanner scanner = new Scanner(System.in);
        System.out.println("請輸入文件路徑:");
        File srcFile = new File(scanner.next());
        System.out.println("請輸入線程數:");
        int n = scanner.nextInt();
        if (!srcFile.exists()) {
            System.out.println("該文件不存在!");
        }

        File desFile = new File(srcFile.getParent(), "new" + srcFile.getName());

     // 從線程數得到每個線程要複製的數據大小
long partLenghth = srcFile.length() / n + 1; for (int i = 1; i < n + 1; i++) {
       // 每次複製的開始和結束位置
new MyThread(srcFile, desFile, partLenghth * (i - 1), partLenghth * i).start(); } } }

--> MyThread類即線程實現類

package com.dragon.java.multithreadcopy;

import java.io.File;
import java.io.IOException;
import java.io.RandomAccessFile;

public class MyThread extends Thread {
    private File srcFile;
    private File desFile;
    private long start;
    private long end;

    MyThread() {
        super();
    }

   // 構造方法傳入源文件、目標文件、本次開始位置以及結束位置 MyThread(File srcFile, File desFile,
long start, long end) { super(); this.srcFile = srcFile; this.desFile = desFile; this.start = start; this.end = end; } @Override public void run() { RandomAccessFile rafSrc = null; RandomAccessFile rafDes = null; try { rafSrc = new RandomAccessFile(srcFile, "r"); rafDes = new RandomAccessFile(desFile, "rw");
       // 將文件指針移動到將要開始複製的位置 rafSrc.seek(start); rafDes.seek(start);
int len = -1; byte[] buffer = new byte[64]; while ((len = rafSrc.read(buffer)) != -1) { rafDes.write(buffer, 0, len);
          // 當讀取到的位置大於或等於要結束的位置時跳出迴圈 if (rafSrc.getFilePointer() >= end) { break; } } } catch (IOException e) { System.out.println(e); } } }

--> -----------------------------------------------------------------------邪惡的分割線----------------------------------------------------------------------------

--> Test測試

import java.util.Scanner;

/*
 * 利用多線程複製文件利用多線程複製文件2
 */
public class Test {
    public static void main(String[] args) {
        @SuppressWarnings("resource")
        Scanner scanner = new Scanner(System.in);
        System.out.println("請輸入文件路徑:");
        File srcFile = new File(scanner.next());
        System.out.println("請輸入線程個數:");
        int n = scanner.nextInt();
        if (!srcFile.exists()) {
            System.out.println("該文件不存在!");
        }

        File desFile = new File(srcFile.getParent(), "new" + srcFile.getName());
long partLenghth = srcFile.length() / n + 1; for (int i = 1; i < n + 1; i++) {
       
// 每次傳入單線程複製的長度 new MyThread(srcFile, desFile, partLenghth, MyThread.getPointer()) .start(); } } }

--> MyThread線程實現類

 1 package com.dragon.java.newthreadcopy;
 2 
 3 import java.io.File;
 4 import java.io.IOException;
 5 import java.io.RandomAccessFile;
 6 
 7 public class MyThread extends Thread {
 8     private File srcFile;
 9     private File desFile;
10     private long partLength;
11     private static long pointer = 0;
12 
13     MyThread() {
14         super();
15     }
16 
17     MyThread(File srcFile, File desFile, long partLength, long pointer) {
18         super();
19         this.srcFile = srcFile;
20         this.desFile = desFile;
21         this.partLength = partLength;
22         MyThread.pointer = pointer;
23     }
24 
25     @Override
26     public void run() {
27         RandomAccessFile rafSrc = null;
28         RandomAccessFile rafDes = null;
29         try {
30             rafSrc = new RandomAccessFile(srcFile, "r");
31             rafDes = new RandomAccessFile(desFile, "rw");
32 
33             rafSrc.seek(pointer);
34             rafDes.seek(pointer);
35 
         // 一次性複製完整的一部分長度 36 byte[] buffer = new byte[(int) partLength]; 37 int len = rafSrc.read(buffer); 38 rafDes.write(buffer, 0, len); 39 pointer = rafSrc.getFilePointer(); 40 } catch (IOException e) { 41 System.out.println(e); 42 } 43 } 44 45 public static long getPointer() { 46 return pointer; 47 } 48 }

--> 感覺第二種也完全是多餘的啊,就是一種方法...


您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • ...
  • 1:過濾器概念 過濾器就是一種在請求目標資源的中間組件,比喻把污水轉換成純凈水中間需要一個污水凈化設備,那麼這個設備就好比一個過濾器。那麼我用圖來表示過濾器(可以有多個過濾器)運行的過程 2:Filter(過濾器)介面 Filter介面包含三個方法分別是init、doFilter、 destroy下 ...
  • //從鍵盤錄入學生信息(僅姓名和成績)並輸出。public class StuInformation {//此處命名用StuScore可能更恰當 String name; double score;}import java.util.Scanner; A_zhi 2016.08.18.22.00 ...
  • 電腦的發展歷史 電腦的學名叫電腦,電腦是用來做計算的。在古時候,人們最早使用的計算工具可能是手指,英文單詞“digit”既有“數字”的意思,又有“手指“的意思。古人用石頭打獵,所以還有可能是石頭來輔助計算。 缺點:手指和石頭太低效了 後來出現了”結繩 “記事。 缺點:結繩慢,繩子還有長度限制。 又 ...
  • 這一篇首先從allitebooks.com里抓取書籍列表的書籍信息和每本書對應的ISBN碼。 一、分析需求和網站結構 allitebooks.com這個網站的結構很簡單,分頁+書籍列表+書籍詳情頁。 要想得到書籍的詳細信息和ISBN碼,我們需要遍歷所有的頁碼,進入到書籍列表,然後從書籍列表進入到每本 ...
  • 1. 基本的代碼結構為: 2. ...
  • 1、 set(集合)——包含了經過排序了的數據,這些數據的值(value)必須是唯一的。 也就是說輸入set容器後得到數據,會去重併排序。 s.insert()插入一個元素 s.begin() s.end()分別返迴首尾指針 s.clear() 清空集合 遍歷需要利用迭代器set<類型>::iter ...
  • 程式主文件標誌if __name__=="__main__": 在程式執行python 1.py 時候 程式1.py __name__ 為 main調用其他文件是,__name__ 為程式自己名字等於__name__ 一切事物都是對象,對象是有類創建的 int 內部功能a = 95b = 10c = ...
一周排行
    -Advertisement-
    Play Games
  • 移動開發(一):使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說,近來想嘗試開發一款安卓APP,考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP,畢竟是使用Visual Studio開發工具,使用起來也比較的順手,結合微軟官方的教程進行了安卓 ...
  • 前言 QuestPDF 是一個開源 .NET 庫,用於生成 PDF 文檔。使用了C# Fluent API方式可簡化開發、減少錯誤並提高工作效率。利用它可以輕鬆生成 PDF 報告、發票、導出文件等。 項目介紹 QuestPDF 是一個革命性的開源 .NET 庫,它徹底改變了我們生成 PDF 文檔的方 ...
  • 項目地址 項目後端地址: https://github.com/ZyPLJ/ZYTteeHole 項目前端頁面地址: ZyPLJ/TreeHoleVue (github.com) https://github.com/ZyPLJ/TreeHoleVue 目前項目測試訪問地址: http://tree ...
  • 話不多說,直接開乾 一.下載 1.官方鏈接下載: https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe,運行開始下載SQL server; 二. ...
  • 前言 隨著物聯網(IoT)技術的迅猛發展,MQTT(消息隊列遙測傳輸)協議憑藉其輕量級和高效性,已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫,為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog支持多種接收器用於日誌存儲,增強器用於添加屬性,LogContext管理動態屬性,支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項,適用於不同需求。 ...
  • 目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據,爬取信息時需要模擬瀏覽器行為,否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下: 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • 1.前言 什麼是熱更新 游戲或者軟體更新時,無需重新下載客戶端進行安裝,而是在應用程式啟動的情況下,在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR,Xlua,ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles,Addressable, ...
  • 本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺,其實像阿裡雲,騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後,它會送 ...
  • 通過以下方式可以高效,並保證數據同步的可靠性 1.API設計 使用RESTful設計,確保API端點明確,並使用適當的HTTP方法(如POST用於創建,PUT用於更新)。 設計清晰的請求和響應模型,以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證,確保接收到的數據符合預期格 ...