快速业务通道

用java多线程断点续传实践 - 编程入门网

作者 佚名技术 来源 NET编程 浏览 发布时间 2012-06-22
  tempFileToTargetFile(childThreads);          } catch (InterruptedException e) {              e.printStackTrace();          } }

用java多线程断点续传实践(2)

时间:2010-12-22 BlogJava bitmap

首先来看最主要的步骤:多线程下载。

首先从url中提取目标文件的名称,并在对应的目录创建文件。然后取得要下 载的文件大小,根据分成的下载线程数量平均分配每个线程需要下载的数据量, 就是threadLength。然后就可以分多个线程来进行下载任务了。

在这个例子中,并没有直接显示的创建Thread对象,而是用Executor来管理 Thread对象,并且用CachedThreadPool来创建的线程池,当然也可以用 FixedThreadPool。CachedThreadPool在程序执行的过程中会创建与所需数量相 同的线程,当程序回收旧线程的时候就停止创建新线程。FixedThreadPool可以 预先新建参数给定个数的线程,这样就不用在创建任务的时候再来创建线程了, 可以直接从线程池中取出已准备好的线程。下载线程的数量是通过一个全局变量 threadNum来控制的,默认为5。

好了,这5个子线程已经通过Executor来创建了,下面它们就会各自为政,互 不干涉的执行了。线程有两种实现方式:实现Runnable接口;继承Thread类。

ChildThread就是子线程,它作为DownloadTask的内部类,继承了Thread,它 的构造方法需要5个参数,依次是一个对 DownloadTask的引用,一个 CountDownLatch,id(标识线程的id号),startPosition(下载内容的开始位 置),endPosition(下载内容的结束位置)。

这个CountDownLatch是做什么用的呢?

现在我们整理一下思路,要实现分多个线程来下载数据的话,我们肯定还要 把这多个线程下载下来的数据进行合。主线程必须等待所有的子线程都执行结束 之后,才能把所有子线程的下载数据按照各自的id顺序进行合并。 CountDownLatch就是来做这个工作的。

CountDownLatch用来同步主线程,强制主线程等待所有的子线程执行的下载 操作完成。在主线程中,CountDownLatch对象被设置了一个初始计数器,就是子 线程的个数5个,代码①处。在新建了5个子线程并开始执行之后,主线程用 CountDownLatch的await()方法来阻塞主线程,直到这个计数器的值到达0,才会 进行下面的操作,代码②处。

对每个子线程来说,在执行完下载指定区间与长度的数据之后,必须通过调 用CountDownLatch的countDown()方法来把这个计数器减1。

2、在全面开启下载任务之后,主线程就开始阻塞,等待子线程执行完毕,所 以下面我们来看一下具体的下载线程ChildThread。

/** *//** *author by http://www.5a520.cn http://www.feng123.com */ public class ChildThread extends Thread {      public static final int STATUS_HASNOT_FINISHED =  0;      public static final int STATUS_HAS_FINISHED = 1;      public static final int STATUS_HTTPSTATUS_ERROR =  2;      private DownloadTask task;      private int id;      private long startPosition;      private long endPosition;      private final CountDownLatch latch;      private File tempFile = null;      //线程状态码      private int status =  ChildThread.STATUS_HASNOT_FINISHED;      public ChildThread(DownloadTask task, CountDownLatch  latch, int id, long startPos, long endPos) {          super();          this.task = task;          this.id = id;          this.startPosition = startPos;

凌众科技专业提供服务器租用、服务器托管、企业邮局、虚拟主机等服务,公司网站:http://www.lingzhong.cn 为了给广大客户了解更多的技术信息,本技术文章收集来源于网络,凌众科技尊重文章作者的版权,如果有涉及你的版权有必要删除你的文章,请和我们联系。以上信息与文章正文是不可分割的一部分,如果您要转载本文章,请保留以上信息,谢谢!

分享到: 更多

Copyright ©1999-2011 厦门凌众科技有限公司 厦门优通互联科技开发有限公司 All rights reserved

地址(ADD):厦门软件园二期望海路63号701E(东南融通旁) 邮编(ZIP):361008

电话:0592-5908028 传真:0592-5908039 咨询信箱:web@lingzhong.cn 咨询OICQ:173723134

《中华人民共和国增值电信业务经营许可证》闽B2-20100024  ICP备案:闽ICP备05037997号