关于JAVA线程问题

Question

因为之前下载是单线程的，考虑到速度问题就改成多线程了。但是发现线程还没有执行完成文夹流就关闭了，在关闭流前我又对线程的状态进行判断，是否因为方法不对，如下是代码。List<Thread> threads=new ArrayList<Thread>();
for(int j=0;j<count;j++){
List<Member> list=new ArrayList<Member>();
list = exportmemberdao.getAllExportCondMemberist("select "+exportconfig_fieldname.substring(0,exportconfig_fieldname.length()-1)+" from member ".concat(cond).concat(" limit "+j*1000+",1000"));
Thread thread=new Thread(new WriteExcel(list, workbook, exportconfig_fieldname, titles,"会员信息"+j));
threads.add(thread);
thread.start();
}

//所有线程是否执行完毕
int index=0;
while(true){
for (Thread thread : threads) {
if(!thread.isAlive()){
System.out.println("线程类:"+thread.getClass().getClass()+" 状态:"+thread.isAlive());
index++;
}
}
if(index==threads.size()){
break;
}
}
String filename=basePath.concat(IConstants.nameSdf.format(new Date())).concat(".xls");
FileOutputStream fileOutputStream=new FileOutputStream(new File(filename));
workbook.write(fileOutputStream);
fileOutputStream.close();最后流关闭后为什么线程中的业务方法还在执行（从控制台中可以看的很明显，我做了输出的）。
就导致我写的文夹不完整。

Answer 1

线程调用start方法有并没有马上启动,但这时while循环先执行了, 这时候就有问题了.
你应该在while前加个Thread.sleep();

Answer 2

可以这样int index=0;
        while(true){
index = 0;
            for (Thread thread : threads) {
                if(!thread.isAlive()){
                    System.out.println("线程类:"+thread.getClass().getClass()+" 状态:"+thread.isAlive());
                    index++;
                }
            }
            if(index==threads.size()){
                break;
            }
        }

Answer 3

其实就是你判断的逻辑不对, 加个index=0意思就相当于每次检查前把上一次的检查结果清空

Answer 4

package com.io;import java.io.File;
import java.io.IOException;
import java.io.RandomAccessFile;
import java.net.HttpURLConnection;
import java.net.URL;public class DownloadFile { /**
 * @param args
 */
static int len;//线程平均下载文件长度
static int bn ;//每个线程写入文件的字节数
static int tn; //线程数
static String urlt;//下载地址
static String fileName;
static RandomAccessFile osf; //文件操作
public static void main(String[] args) {
// TODO Auto-generated method stub

try {
urlt = "http://im.baidu.com/download/BaiduHi_4.2_Beta.exe";
fileName = "C:\\" + urlt.split("//")[1].split("/")[urlt.split("//")[1].split("/").length-1];
System.out.println(fileName);
URL url = new URL(urlt);
HttpURLConnection http = (HttpURLConnection) url.openConnection(); /**
 * 此处设定5个线程下载一个文件tn = 5;
 * 判断平均每个线程需下载文件长度：
 */
System.out.println("file size:" + http.getContentLength());
tn = 3;
//舍去余数（余数自动舍去）计算每个线程应下载平均长度，最后一个线程再加上余数，则是整个文件的长度,
len = http.getContentLength() / tn ;
File f = new File(fileName);
if (f.exists()){
f.delete();
osf = new RandomAccessFile(f, "rw");
osf.seek(http.getContentLength()-1);
osf.write(0);
}else{
osf = new RandomAccessFile(f, "rw");
osf.seek(http.getContentLength()-1);
osf.write(0);
}
System.out.println("temp 文件长度：" + f.length());
Thread t;//下载子线程，
for (int j = 0; j < tn; j++) {
if(j == tn - 1){
//如果最后一个线程则加上余数长度字节
bn = len + (http.getContentLength() % tn);
}else{
bn = len;
}
System.out.println("t"+ j + "线程下载长度：" + bn + "起始字节：" + len*j);
t = new DT(
j,
urlt,
fileName,
len*j,
bn
);
t.start();
} } catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}}

Answer 5

package com.io;import java.io.File;
import java.io.FileNotFoundException;
import java.io.IOException;
import java.io.InputStream;
import java.io.RandomAccessFile;
import java.net.HttpURLConnection;
import java.net.MalformedURLException;
import java.net.URL;
import java.util.Date;public class DT extends Thread { String urlt; int startl; int end; String fileName; RandomAccessFile osf; public DT(int i, String url, String fileName, int start, int end) {
this.setName("t" + i); // 子线程名称
this.urlt = url; // 下载地址
this.fileName = fileName;
this.startl = start; // 子线程读取/写入起始字节
this.end = end;// 子线程写入结束字节长度
} public void run() {
try {
osf = new RandomAccessFile(fileName, "rw");
URL url = new URL(urlt);
HttpURLConnection http2 = (HttpURLConnection) url.openConnection();
http2.setRequestProperty("User-Agent", "NetFox"); /*
 * 断点续传和多线程下载的关键代码关键位置：即设置断点 http2.setRequestProperty("RANGE",
 * "bytes="+startl+"-");//设置断点位置，向服务器请求从文件的哪个字节开始读取。
 * osf.seek(startl);//设置本地文件从哪个字节开始写入 如果是单线程，则首先要判断下载文件是否已经存在
 * 及DownloadFile.java 里的 fileName = "C:\\eclipse.zip";
 * 如果存在则开始断点续传，方法同多线程：
 * 因为断点续传是从上次传输中断的字节开始，则首先要得到上次中断的位置，既是文件长度（针对单线程）f.length()
 * 然后设置HTTP请求头属性RANGE，该属性告知服务器从哪个自己开始读取文件。
 * 设置本地文件写入起始字节，及接从上次传输断点继续写入（断点续传） osf.seek(offset)
 * 该方法设定从offset后一个字节开始写入文件
 * 注意：多线程不能用文件长度做为写文件起始字节，需有配置文件记录上次读写的位置，迅雷下载既是使用该种方法。
 * 
 */
http2.setRequestProperty("RANGE", "bytes=" + startl + "-");// 设置断点位置，向服务器请求从文件的哪个字节开始读取。
osf.seek(startl);// 设置本地文件从哪个字节开始写入 InputStream input = http2.getInputStream();
byte b[] = new byte[1024];// 设置缓冲池，每次只读1024字节
Date d = new Date();// 子线程开始下载时间
int l;// 计算子线程读取和写入的文件长度，当长度大于每个子线程平均下载长度则终止线程
int i;
l = 0;
System.out.println(this.getName() + " 开始下载");
while ((i = input.read(b, 0, 1024)) != -1 && l < end) { // 线程下载字节长度控制误差小于缓冲池大小，本示例为缓冲池1024字节
osf.write(b, 0, i);
b = new byte[1024];// 重新赋值，避免重新读入旧内容
l += i;
}
Date d2 = new Date();// 子线程结束下载时间
System.out.println(this.getName() + " 线程耗时： "
+ (d2.getTime() - d.getTime()) / 1000 + " 秒,实际共下载：" + l
+ "字节");// 子线程下载耗时（秒）
} catch (FileNotFoundException e1) {
// TODO Auto-generated catch block
e1.printStackTrace();
} catch (MalformedURLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} }}

Answer 6

这句说的很对啊！每次都清空index

Answer 7

网络IO的确在那里, 但是多线程的好处就是你可以少卡在网络IO那里