初識JAVA多線程編程

java多線程

1. 術語辨析

任務和線程是不一樣的,Java中Thread類自己不執行任何操做,它只驅動賦予它的任務,而Runnable纔是定義任務的地方.

2. 建立任務的方式有兩種

2.1 實現Runnable接口中的run方法

1.查看Runnable源碼,能夠看到只有一個run()方法

@FunctionalInterface
public interface Runnable {
    /**
     * When an object implementing interface <code>Runnable</code> is used
     * to create a thread, starting the thread causes the object's
     * <code>run</code> method to be called in that separately executing
     * thread.
     * <p>
     * The general contract of the method <code>run</code> is that it may
     * take any action whatsoever.
     *
     * @see     java.lang.Thread#run()
     */
    public abstract void run();
}

2.使用Runnable,直接繼承便可,這樣就建立了一個任務.

public class MyRunnable implements Runnable{

    @Override
    public void run() {
        int i=0;
        while(true)
            System.out.println(i++);
    }
    //暗示調度器該線程可讓出資源了
    Thread.yield();
}

2.2 Thread中實現run方法

1.Thread部分源碼

/*
 * @see     Runnable
 * @see     Runtime#exit(int)
 * @see     #run()
 * @see     #stop()
 * @since   JDK1.0
 */
public class Thread implements Runnable {
    /* Make sure registerNatives is the first thing <clinit> does. */
    private static native void registerNatives();
    static {
        registerNatives();
    }

2.能夠看到Thread繼承了Runnable接口,因此Thread建立任務也是用的run方法
3.代碼能夠這樣寫

class MyThread extends Thread{
    @Override
    public void run() {
        int count=10;
        while(count--!=0)
            System.out.print(count+" ");
    }
}

3. 運行任務

1.不要誤會,下面的方法並未啓動一個線程,而是單純的調用了實現Runnable接口的MyRunnable的run()方法,因此該任務的運行依舊被分派到該main線程中,不會獨立運行在一個新線程裏.

public class Main{
    public static void main(String[] args){
        Runnable runnable=new Runnable();
        runnable.run();
    }
}

2.調用Thread的start(),Thread中記錄了不少線程信息,包括線程名稱和優先級等,以MyRunnable的實例做參傳入Thread,而後start便可運行.

public static void main(String[] args){

Thread thread=new Thread(new MyRunnable);
thread.start()
}

3.在調用start()後,子線程不會由於主線程代碼執行結束而中止.

4. 使用執行器(Executor)管理Thread.

public static void main(String[] args){

    //常見執行器對象
    ExecutorService executorService= Executors.newCachedThreadPool();
    //向執行器中添加任務
    executorService.execute(new MyRunnable());
    //關閉向執行器中添加任務;
    executorService.shutdown();

建立執行器又三種類型可選,分別是newCachedThreadPool,newFixedThreadPool,newSingleThreadPool,區別以下

1. newCachedThreadPool:系統自動調配線程池中的線程數量,並主動複用已完成的線程資源.
2. newFixedThreadPool:能夠自定義線程池中線程數量;
3. newSingleThreadPool:單例,線程池中只有一個線程,加載的任務會被排隊,任務只能一個個依次完成.

5.線程的返回值

1.有些任務執行完後須要返回值,那麼建立任務時能夠經過實現Callale接口而實現該目的,Callable是一種具備類型參數的泛型,由於返回值是須要定義類型的.

class Task implements Callable<String>{

    @Override
    public String call() throws Exception {
        Thread.currentThread().setPriority(Thread.MAX_PRIORITY);
        TimeUnit.MILLISECONDS.sleep(100);
        return "線程執行啦";
    }
}

2.而後在main()方法中接受返回值信息,對線程信息的管理能夠用Future<String>

public static void main(String[] args){
    ExecutorService executorService=Executors.newCachedThreadPool();
    Future<String> future=executorService.submit(new Callable<String>(){    
        @Override   
        public String call() throws Exception {
        return "執行啦";   
        }
    });
    //判斷是否完成
    System.out.println(future.isDone());
    //任務完成後,纔會打印詞條語句,不然會阻塞.
    System.out.println(future.get());
    //判斷是否完成
    System.out.println(future.isDone());
}
----------輸出----------
false
執行啦
true

3.程序運行到get()方法時會阻塞,當運行完後,主程序纔會繼續向後執行.

6. 程序的優先級

1.優先級的設置在run方法中

public void run(){

    //例如將優先級設置爲10
    Thread.currentThread().setPriority(10)
}

2.爲了方便移植,建議將優先級設置爲Thread中的三個常量.

7. 後臺線程

1.設置後臺線程語法 thread.setDaemon(true);要在start()以前.2.後臺線程建立的線程也爲後臺線程.