package cn.thread.線程;

public class MyThread extends Thread{
    public MyThread(String name){
        super(null,null,name);
    }
    int piao =10;
    @Override
    public void run() {
        while(piao>0){
            System.out.println(Thread.currentThread().getName()+"......"+piao--);
        }
    }

    public static void main(String[] args) {
        MyThread mt = new MyThread("x");
        mt.run();
    }
}

package cn.thread.線程;

public class MyRunnable implements Runnable{

    int piao = 10;
    @Override
    public void run() {
        while(piao>0){
            System.out.println(Thread.currentThread().getName()+"-----"+piao--);
        }
    }

    public static void main(String[] args) {
        Runnable r =new MyRunnable();
        Thread t =new Thread(r);
        t.start();
    }

}

package com.openlab.test;

import java.util.Random;
import java.util.concurrent.Callable;

public class CallableTest implements Callable{

	@Override
	public Object call() throws Exception {
		
		Random generator = new Random();
		
		Integer randomNumber = generator.nextInt(5);
		
		Thread.sleep(randomNumber*1000);
		
		return randomNumber;
	}

}

package cn.thread.線程;

import java.util.ArrayList;
import java.util.Date;
import java.util.List;
import java.util.Random;
import java.util.concurrent.*;

public class CallableTest implements Callable<Object> {//不能直接創(chuàng)建線程
    int taskNum;
    public CallableTest(int taskNum){
        this.taskNum = taskNum;

    }
    @Override
    public Object call() throws Exception {

        System.out.println(">>>"+taskNum+"任務(wù)啟動(dòng)");
        Date dataTemp = new Date();
        Thread.sleep(1000);
        Date dataTemp2 = new Date();
        long time  = dataTemp2.getTime() - dataTemp.getTime();
        System.out.println(">>>>"+taskNum+"任務(wù)終止");
        return taskNum+"任務(wù)返回運(yùn)行結(jié)果"+time;
//        Random generator = new Random();
//        Integer randomNumber = generator.nextInt(5);
//        Thread.sleep(randomNumber*1000);
//        return  randomNumber;
    }
    /*test1方法采用Executors的靜態(tài)方法newFixedThreadPool(taskSize) 創(chuàng)建一個(gè)可重用固定線程集合的
    線程池，以共享的無(wú)界隊(duì)列方式來(lái)運(yùn)行這些線程，獲取線程池。ExecutorService的submit方法提交一個(gè)
    callable實(shí)例，得到一個(gè)future對(duì)象，最終將future對(duì)象存儲(chǔ)在list數(shù)組中，加入線程池的過(guò)程中就代表
    著線程已經(jīng)開(kāi)始執(zhí)行，相當(dāng)于一個(gè)線程池代理過(guò)程，就不需要采用start方法啟動(dòng)線程。最后對(duì)future進(jìn)行
    打印輸出。切記一定要關(guān)閉線程池！*/
     static void test1() throws ExecutionException, InterruptedException {
         System.out.println("程序開(kāi)始");
         Date data1 = new Date();
         int taskSize = 5;
        //構(gòu)建線程池對(duì)象
         ExecutorService pool = Executors.newFixedThreadPool(taskSize);
         List<Future> list =new ArrayList<Future>();
         for(int i=0;i<taskSize;i++){

             Callable c = new CallableTest(i);
             Future f = pool.submit(c);
             list.add(pool.submit(c));

         }
         //關(guān)閉線程池
         pool.shutdown();
         for(Future f:list){
             System.out.println(">>>"+f.get().toString());
         }
         Date date2 = new Date();
         System.out.println("程序運(yùn)行結(jié)束-----"+(date2.getTime()-data1.getTime())+"毫秒");
     }
     /*test2方法主要是采用futuretask類，可以直接把callable作為參數(shù)來(lái)申明futuretask對(duì)象，
     這里相當(dāng)于把線程池?fù)Q成了futuretask數(shù)組，因?yàn)閠est1線程池可以對(duì)callable進(jìn)行封裝，
     在這里可以直接采用futuretask就行封裝，在加上futuretask又實(shí)現(xiàn)了runnable接口，
     所以可以直接創(chuàng)建線程采用start的方式進(jìn)行啟動(dòng)線程。*/
     static  void test2() throws ExecutionException, InterruptedException {
         System.out.println("----程序開(kāi)始-----");
         Date date1 =new Date();
         int taskSize = 5;
         FutureTask[] randNumber = new FutureTask[taskSize];
         List<Future> list =new ArrayList<Future>();
         for(int i=0;i<taskSize;i++){
             Callable c = new CallableTest(i);
             randNumber[i] = new FutureTask(c);
             Thread t = new Thread(randNumber[i]);
             t.start();

         }
         for(Future f:randNumber){
             System.out.println(">>>"+f.get().toString());
         }
         Date date2 = new Date();
         System.out.println("程序運(yùn)行結(jié)束-----"+(date2.getTime()-date1.getTime())+"毫秒");

     }
    public static void main(String[] args) throws Exception {
//        CallableTest c = new CallableTest();
//        Integer i = (Integer) c.call();
        test1();
        test2();

    }
}

// 創(chuàng)建線程池
 ExecutorService threadPool = Executors.newFixedThreadPool(10);
 while(true) {
 threadPool.execute(new Runnable() { // 提交多個(gè)線程任務(wù)，并執(zhí)行
 @Override
 public void run() {
 System.out.println(Thread.currentThread().getName() + " is running ..");
 try {
 Thread.sleep(3000);
 } catch (InterruptedException e) {
 e.printStackTrace();
 }
 }
 });
 } }