黑马程序员技术交流社区

标题: 多线程下载问题 [打印本页]
作者: itpower    时间: 2014-1-24 22:28
标题: 多线程下载问题
如果没有加同步块虽然下载完毕的文件是正确的但是进度确实99%，加了同步块之后就是100%了。想了好几天没想出来到底是哪里出了同步问题。加法不应该会有同步问题啊？






  1. package com.java.test;

  3. import java.io.File;
  4. import java.io.FileNotFoundException;
  5. import java.io.IOException;
  6. import java.io.InputStream;
  7. import java.io.RandomAccessFile;
  8. import java.net.HttpURLConnection;
  9. import java.net.MalformedURLException;
  10. import java.net.URL;

  12. public class UpdateReceiver {
  13.         private static int length=0;
  14.         private RandomAccessFile accessFile;
  15.         private static Object object=new Object();
  16.         public static void main(String[] args) {
  17.                 new UpdateReceiver().download("http://gdown.baidu.com/data/wisegame/3cf61f0c7216ed52/UCliulanqi_90.apk",3); // 开启三条线程进行文件的下载
  18.         }

  20.         /**
  21.          * 多线程下载文件
  22.          *
  23.          * @param path
  24.          *            网络文件URL
  25.          * @param threadNum
  26.          *            开启的线程数
  27.          */
  28.         public void download(String path, int threadNum) {
  29.                 try {
  30.                         URL url = new URL(path);
  31.                         HttpURLConnection conn = (HttpURLConnection) url.openConnection();
  32.                         conn.setConnectTimeout(3000);
  33.                         conn.setRequestMethod("GET");
  34.                         if (conn.getResponseCode() == 200) {
  35.                                 int fileLength = conn.getContentLength(); // 获取网络文件大小
  36.                                 File file = new File("d://a", "b.exe");
  37.                                 accessFile = new RandomAccessFile(file, "rwd");
  38.                                 accessFile.setLength(fileLength); // 在本地生成相同大小的一个文件 }
  39.                                 int block = fileLength % threadNum == 0 ? fileLength/ threadNum : (fileLength / threadNum) + 1; // 每条线程负责下载的数据量
  40.                                 for (int threadId = 0; threadId < threadNum; threadId++) {
  41.                                         new DownloadThread(threadId, block, path, file).start();
  42.                                 }
  43.                         }
  44.                 } catch (MalformedURLException e) {
  45.                         e.printStackTrace();
  46.                 } catch (IOException e) {
  47.                         e.printStackTrace();
  48.                 }
  49.         }

  51.         public class DownloadThread extends Thread {
  52.                 private int threadId;
  53.                 private int block;
  54.                 private String path;
  55.                 private File file;

  57.                 public DownloadThread(int threadId, int block, String path, File file) {
  58.                         this.threadId = threadId;
  59.                         this.block = block;
  60.                         this.path = path;
  61.                         this.file = file;
  62.                 }

  64.                 public void run() {
  65.                         super.run();
  66.                         int start = threadId * block; // 计算线程从网络文件哪一处开始下载
  67.                         int end = (threadId + 1) * block - 1; // 计算线程下载到网络文件的什么位置
  68.                         InputStream in = null;
  69.                         RandomAccessFile accessFile = null;
  70.                         try {
  71.                                 accessFile = new RandomAccessFile(file, "rwd");
  72.                                 accessFile.seek(start);
  73.                                 URL url = new URL(path);
  74.                                 HttpURLConnection conn = (HttpURLConnection) url.openConnection();
  75.                                 conn.setConnectTimeout(3000);
  76.                                 conn.setRequestMethod("GET");
  77.                                 conn.setRequestProperty("Range", "bytes=" + start + "-" + end);// 设置该头字段表示下载一部分数据
  78.                                 if (conn.getResponseCode() == 206) {// 请求范围时返回码应为206
  79.                                         in = conn.getInputStream();
  80.                                         byte[] buffer = new byte[1024];
  81.                                         int len = 0;
  82.                                         while ((len = in.read(buffer)) != -1) {
  83.                                                 synchronized (object) {
  84.                                                         accessFile.write(buffer,0, len);
  85.                                                         length+=len;
  86.                                                         System.out.println(length*100/accessFile.length()+"%");
  87.                                                 }
  88.                                         }
  89.                                 }
  90.                         } catch (FileNotFoundException e) {
  91.                                 e.printStackTrace();
  92.                         } catch (IOException e) {
  93.                                 e.printStackTrace();
  94.                         } finally {
  95.                                 try {
  96.                                         System.out.println("length:"+length);
  97.                                         System.out.println("第"+(threadId+1)+"条线程下载完毕");
  98.                                         if (accessFile != null && in != null) {
  99.                                                 accessFile.close();
  100.                                                 in.close();
  101.                                         }
  102.                                 } catch (IOException e) {
  103.                                         e.printStackTrace();
  104.                                 }
  105.                         }
  106.                 }

  108.         }

  110. }
复制代码



作者: e.c    时间: 2014-1-29 21:50
synchronized (object) {
  length+=len;
  System.out.println(length*100/accessFile.length()+"%");
}
加锁只加在变量这里就可以了，文件操作不用。




欢迎光临 黑马程序员技术交流社区 (http://bbs.itheima.com/) 黑马程序员IT技术论坛 X3.2