多线程下载类

下载线程类&＃xff1a;

实现步骤&＃xff1a;

0准备

线程下载需要的数据建立对应的属性&＃xff08;开始位置&＃xff0c;结束位置&＃xff0c;线程数&＃xff0c;并创建构造函数&＃xff09;

//多线程下载需要的信息
private long startIndex;
private long endIndex;
private int threadId;
public DownLoad2(long startIndex, long endIndex, int threadId) {super();this.startIndex &＃61; startIndex;this.endIndex &＃61; endIndex;this.threadId &＃61; threadId;
}

具体的run方法中&＃xff1a;

1通过URL和下载资源建立联系

//统一资源管理器&＃xff0c;可以直接打开网络地址
URL url &＃61; new URL(DownLoadTest2.path);
//因为是基于Http请求&＃xff0c;获取httpUrlConnection,获取网络连接对象&＃xff0c;和服务器建立联系
HttpURLConnection conn &＃61; (HttpURLConnection) url.openConnection();
​

2设置参数&＃xff0c;读取的范围

//设置参数
conn.setRequestMethod("GET");
conn.setConnectTimeout(50000);//连接超时
conn.setReadTimeout(50000);//读取超时
conn.addRequestProperty("Range", "bytes&＃61;"&＃43;startIndex&＃43;"-"&＃43;endIndex);//设置读取范围

3开始进行文件的读取和写入(保护文件读取时的判断&＃xff08;是否读取成功&＃xff09;)

if(conn.getResponseCode()&＃61;&＃61;206) {//部分数据ok//取出连接中的数据InputStream is &＃61; conn.getInputStream();//提供一个接收的地方&＃xff08;本地接收&＃xff09;File file &＃61; new File("D:\\upload\\MSangoSetup2.0.0.80.zip");//输出流&＃xff0c;开始写数据&＃xff0c;随机读写流RandomAccessFile raf &＃61; new RandomAccessFile(file, "rwd");raf.seek(startIndex);//跳转到线程开始的位置//具体的读写操作byte [] buf&＃61; new byte[8192];//字节数组&＃xff0c;提高读取速度int len&＃61;0;//字节数组读取的长度while((len&＃61;is.read(buf))!&＃61;-1) {raf.write(buf, 0, len);}raf.close();is.close();//线程完成下载&＃xff0c;完成下载线程数加一DownLoadTest2.okThread&＃43;&＃43;;//同步代码块&＃xff0c;线程下载数量和总线程数量一致时&＃xff0c;完成下载线程数量归零synchronized (DownLoadTest2.path) {System.out.println("线程:"&＃43;this.getName()&＃43;threadId&＃43;"下载完毕...   "&＃43;DownLoadTest2.okThread);if(DownLoadTest2.okThread&＃61;&＃61;DownLoadTest2.countThread) {DownLoadTest2.okThread&＃61;0;}}
}

多线下载测试类

准备

static String path &＃61; "http://download2.m3guo.com/MSangoSetup1.2.22.51.exe";//资源地址
static int countThread&＃61;14;//线程数
static int okThread&＃61;0;//和线程数有关&＃xff0c;记录线程完成的个数

main方法内容

1通过URL和下载资源建立联系

//统一资源管理器&＃xff0c;可以直接打开网络地址
URL url &＃61; new URL(DownLoadTest2.path);
//因为是基于Http请求&＃xff0c;获取httpUrlConnection,获取网络连接对象&＃xff0c;和服务器建立联系
HttpURLConnection conn &＃61; (HttpURLConnection) url.openConnection();

2设置参数

//设置参数
conn.setRequestMethod("GET");
conn.setConnectTimeout(50000);//连接超时
conn.setReadTimeout(50000);//读取超时

3判断资源链接是否建立成功&＃xff0c;成功进行多线程下载分配

if(conn.getResponseCode()&＃61;&＃61;200) {//成功//获取文件总长度long count &＃61; conn.getContentLengthLong();//每个线程下载的大小long size &＃61; count/countThread;//开启线程进行下载for (int i &＃61; 0; i

Java 多线程编程

Java 给多线程编程提供了内置的支持。 一条线程指的是进程中一个单一顺序的控制流&＃xff0c;一个进程中可以并发多个线程&＃xff0c;每条线程并行执行不同的任务。

一个线程的生命周期

线程是一个动态执行的过程&＃xff0c;它也有一个从产生到死亡的过程。

• 新建状态:

  使用 new 关键字和 Thread 类或其子类建立一个线程对象后&＃xff0c;该线程对象就处于新建状态。它保持这个状态直到程序 start() 这个线程。

• 就绪状态:

  当线程对象调用了start()方法之后&＃xff0c;该线程就进入就绪状态。就绪状态的线程处于就绪队列中&＃xff0c;要等待JVM里线程调度器的调度。

• 运行状态:

  如果就绪状态的线程获取 CPU 资源&＃xff0c;就可以执行 run()&＃xff0c;此时线程便处于运行状态。处于运行状态的线程最为复杂&＃xff0c;它可以变为阻塞状态、就绪状态和死亡状态。

• 阻塞状态:

  如果一个线程执行了sleep&＃xff08;睡眠&＃xff09;、suspend&＃xff08;挂起&＃xff09;等方法&＃xff0c;失去所占用资源之后&＃xff0c;该线程就从运行状态进入阻塞状态。在睡眠时间已到或获得设备资源后可以重新进入就绪状态。可以分为三种&＃xff1a;

• 死亡状态:

  一个运行状态的线程完成任务或者其他终止条件发生时&＃xff0c;该线程就切换到终止状态。

创建一个线程

Java 提供了三种创建线程的方法&＃xff1a;

• 通过实现 Runnable 接口&＃xff1b;

• 通过继承 Thread 类本身&＃xff1b;

• 通过 Callable 和 Future 创建线程。