package cn.java.core.ch03.job.job03;
import java.util.Scanner;
public class MultiCalc {
private long startTime = 0L;
private long endTime =0L;
private long totalResult = 0L;
private Boolean[] isCompleted = null;
public static void main(String[] args) {
(new MultiCalc()).startUp();
}
private boolean isSuccessed(){
for(int i=0;i<isCompleted.length;i++){
if (!isCompleted[i])
return false;
}
return true;
}
private void startUp(){
int threadNum;
long numbers = 100L;
System.out.println("請輸入要開啟的線程數");
Scanner input = new Scanner(System.in);
threadNum = input.nextInt();
isCompleted = new Boolean[threadNum];
System.out.println("開始計時....");
startTime = System.currentTimeMillis();
for(int i=1;i<=threadNum;i++){
isCompleted[i-1] =false;
Thread t = new Thread(new CalcThread(i,numbers,threadNum));
t.start();
}
synchronized (MultiCalc.this) {
try {
MultiCalc.this.wait();
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
endTime = System.currentTimeMillis();
System.out.println("計算結果為:"+totalResult);
System.out.println("計時結束,總耗時為:"+(endTime-startTime)+"ms");
}
class CalcThread implements Runnable{
private long start;
private long end;
private long result;
private int threadIndex;
public CalcThread(int threadIndex,long numbers,int threadNum){
long step = numbers/threadNum;
this.threadIndex = threadIndex;
start = (threadIndex-1)*step+1;
if (threadIndex==threadNum){ //是否是最后一個線程
end = numbers;
}else{
end = threadIndex*step;
}
//System.out.println(Thread.currentThread().getName()+
//"---->"+start+"~"+end);
}
@Override
public void run() {
for(long i=start;i<=end;i++){
try {
Thread.sleep(10);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
result+=i;
}
//System.out.println(result);
synchronized (MultiCalc.this) {
totalResult +=result;
isCompleted[this.threadIndex-1] = true;
if (isSuccessed()){
MultiCalc.this.notify();
}
}
//System.out.println(totalResult);
}
}
}
