java中ThreadAPI的調(diào)用規(guī)則是什么

這篇文章將為大家詳細(xì)講解有關(guān)java中Thread API的調(diào)用規(guī)則是什么,文章內(nèi)容質(zhì)量較高,因此小編分享給大家做個(gè)參考,希望大家閱讀完這篇文章后對(duì)相關(guān)知識(shí)有一定的了解。

師宗網(wǎng)站制作公司哪家好,找創(chuàng)新互聯(lián)建站!從網(wǎng)頁(yè)設(shè)計(jì)、網(wǎng)站建設(shè)、微信開發(fā)、APP開發(fā)、響應(yīng)式網(wǎng)站建設(shè)等網(wǎng)站項(xiàng)目制作,到程序開發(fā),運(yùn)營(yíng)維護(hù)。創(chuàng)新互聯(lián)建站成立于2013年到現(xiàn)在10年的時(shí)間,我們擁有了豐富的建站經(jīng)驗(yàn)和運(yùn)維經(jīng)驗(yàn),來(lái)保證我們的工作的順利進(jìn)行。專注于網(wǎng)站建設(shè)就選創(chuàng)新互聯(lián)建站

start一個(gè)Thread

Thread中有兩個(gè)方法,一個(gè)是start方法,一個(gè)是run方法,兩個(gè)都可以調(diào)用,那么兩個(gè)有什么區(qū)別呢?

先看一下start方法:

public synchronized void start() {

        if (threadStatus != 0)
            throw new IllegalThreadStateException();
        group.add(this);
        boolean started = false;
        try {
            start0();
            started = true;
        } finally {
            try {
                if (!started) {
                    group.threadStartFailed(this);
                }
            } catch (Throwable ignore) {
            }
        }
    }

    private native void start0();

start()是一個(gè)synchronized的方法,通過它會(huì)去調(diào)用native的start0方法,而最終將會(huì)調(diào)用Thread的run()方法。

我們知道,創(chuàng)建一個(gè)Thread有兩種方式,一種是傳入一個(gè)Runnable,一個(gè)是繼承Thread,并重寫run()方法。

如果我們直接調(diào)用Thread的run()方法會(huì)發(fā)生什么事情呢?

先看一下run方法的定義:

    public void run() {
        if (target != null) {
            target.run();
        }
    }

默認(rèn)情況下, 這個(gè)target就是一個(gè)Runnable對(duì)象,如果Thread是通過Runnable來(lái)構(gòu)建的話,調(diào)用Thread.run()會(huì)在當(dāng)前線程中運(yùn)行run方法中的內(nèi)容。

如果Thread是以其形式構(gòu)建,并且沒有重新run()方法,那么直接調(diào)用Thread.run()將什么都不會(huì)做。

    public void wrongStart(){
        Runnable runnable= ()-> System.out.println("in thread running!");
        Thread thread= new Thread(runnable);
        thread.run();
    }

    public void correctStart(){
        Runnable runnable= ()-> System.out.println("in thread running!");
        Thread thread= new Thread(runnable);
        thread.start();
    }

所以,上面兩種調(diào)用方式,只有第二種是正確的。

不要使用ThreadGroup

Thread中有個(gè)字段類型是java.lang.ThreadGroup,這個(gè)主要是用來(lái)給Thread進(jìn)行分組,我們看下Thread的這個(gè)構(gòu)造函數(shù):

 public Thread(ThreadGroup group, Runnable target) {
        this(group, target, "Thread-" + nextThreadNum(), 0);
    }

上面的構(gòu)造函數(shù)可以在傳入runnable的同時(shí)傳遞一個(gè)ThreadGroup對(duì)Thread進(jìn)行分組。

如果沒有指定ThreadGroup,那么將會(huì)為其分配一個(gè)默認(rèn)的default group。

ThreadGroup是做什么的呢?ThreadGroup是java 1.0引入的方法,主要是一次性的對(duì)一組thread進(jìn)行操作。我們可以調(diào)用ThreadGroup.interrupt()來(lái)一次性的對(duì)整個(gè)Group的Thread進(jìn)行interrupts操作。

雖然ThreadGroup提供了很多有用的方法,但是其中很多方法都被廢棄了,比如:allowThreadSuspension(), resume(), stop(), 和 suspend(),并且ThreadGroup中還有很多方法是非線程安全的:

  • ThreadGroup.activeCount()

這個(gè)方法主要是用來(lái)統(tǒng)計(jì)一個(gè)ThreadGroup中活動(dòng)的線程個(gè)數(shù),這個(gè)方法會(huì)統(tǒng)計(jì)還未啟動(dòng)的線程,同時(shí)也會(huì)受系統(tǒng)線程的影響,所以是不準(zhǔn)確的。

  • ThreadGroup.enumerate()

這個(gè)方法是將ThreadGroup和子group的線程拷貝到一個(gè)數(shù)組中,但是如果數(shù)組太小了,多余的線程是會(huì)被自動(dòng)忽略的。

ThreadGroup本身有一個(gè) stop() 方法用來(lái)停止所有的線程,但是stop是不安全的,已經(jīng)被廢棄了。

那么我們?cè)撛趺慈グ踩耐V购芏鄠€(gè)線程呢?

使用executor.shutdown()就可以了。

不要使用stop()方法

剛剛講了ThreadGroup中不要調(diào)用stop()方法,因?yàn)閟top是不安全的。

調(diào)用stop方法會(huì)立馬釋放線程持有的所有的鎖,并且會(huì)拋出ThreadDeath異常。

因?yàn)闀?huì)釋放所有的鎖,所以可能會(huì)造成受這些鎖保護(hù)的對(duì)象的狀態(tài)發(fā)生不一致的情況。

替代的方法有兩種,一種是使用volatile flag變量,來(lái)控制線程的循環(huán)執(zhí)行:

    private volatile boolean done = false;

    public void shutDown(){
        this.done= true;
    }

    public void stopWithFlag(){

        Runnable runnable= ()->{
            while(!done){
                System.out.println("in Runnable");
            }
        };

        Thread thread= new Thread(runnable);
        thread.start();
        shutDown();
    }

另外一種方法就是調(diào)用interrupt(), 這里我們要注意interrupt()的使用要點(diǎn):

  1. 如果當(dāng)前線程實(shí)例在調(diào)用Object類的wait(),wait(long)或wait(long,int)方法或join(),join(long),join(long,int)方法,或者在該實(shí)例中調(diào)用了Thread.sleep(long)或Thread.sleep(long,int)方法,并且正在阻塞狀態(tài)中時(shí),則其中斷狀態(tài)將被清除,并將收到InterruptedException。

  2. 如果此線程在InterruptibleChannel上的I/O操作中處于被阻塞狀態(tài),則該channel將被關(guān)閉,該線程的中斷狀態(tài)將被設(shè)置為true,并且該線程將收到j(luò)ava.nio.channels.ClosedByInterruptException異常。

  3. 如果此線程在java.nio.channels.Selector中處于被被阻塞狀態(tài),則將設(shè)置該線程的中斷狀態(tài)為true,并且它將立即從select操作中返回。

  4. 如果上面的情況都不成立,則設(shè)置中斷狀態(tài)為true。

先看下面的例子:

    public static void main(String[] args)  {
        Runnable runnable= ()->{
            while (!Thread.interrupted()) {
             System.out.println("in thread");
            }
        };
        Thread thread= new Thread(runnable);
        thread.start();
        Thread.sleep(5000);
        thread.interrupt();
    }

我們?cè)趙hile循環(huán)中調(diào)用了Thread.interrupted()方法用來(lái)判斷線程是否被設(shè)置了中斷位,然后在main方法中調(diào)用了thread.interrupt()來(lái)設(shè)置中斷,最終可以正確的停止Thread。

注意,這里運(yùn)行的Thread并沒有被阻塞,所以并不滿足我們上面提到的第一個(gè)條件。

下面我們?cè)倏匆粋€(gè)例子:

    public static void main(String[] args)  {
        Runnable runnable= ()->{
            while (!Thread.interrupted()) {
             System.out.println("in thread");
                try {
                    Thread.sleep(5000);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        };

        Thread thread= new Thread(runnable);
        thread.start();
        thread.interrupt();
    }

這個(gè)例子和上面的例子不同之處就是在于,Thread中調(diào)用了sleep方法,導(dǎo)致Thread被阻塞了,最終滿足了第一個(gè)條件,從而不會(huì)設(shè)置終端位,只會(huì)拋出InterruptedException,所以這個(gè)例子中線程是不會(huì)被停止的,大家一定要注意。

wait 和 await 需要放在循環(huán)中調(diào)用

為什么要放在循環(huán)中呢?因?yàn)槲覀兿M鹷ait不是被錯(cuò)誤的被喚醒,所以我們需要在wait被喚醒之后,重新檢測(cè)一遍條件。

錯(cuò)誤的調(diào)用是放在if語(yǔ)句中:

synchronized (object) {
  if (<condition does not hold>) {
    object.wait();
  }
  // Proceed when condition holds
}

正確的方法是放在while循環(huán)中:

synchronized (object) {
  while (<condition does not hold>) {
    object.wait();
  }
  // Proceed when condition holds
}

關(guān)于java中Thread API的調(diào)用規(guī)則是什么就分享到這里了,希望以上內(nèi)容可以對(duì)大家有一定的幫助,可以學(xué)到更多知識(shí)。如果覺得文章不錯(cuò),可以把它分享出去讓更多的人看到。

新聞標(biāo)題:java中ThreadAPI的調(diào)用規(guī)則是什么
轉(zhuǎn)載源于:http://m.kartarina.com/article40/geceeo.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián),為您提供虛擬主機(jī)網(wǎng)站排名全網(wǎng)營(yíng)銷推廣App設(shè)計(jì)網(wǎng)站改版企業(yè)建站

廣告

聲明:本網(wǎng)站發(fā)布的內(nèi)容(圖片、視頻和文字)以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主,如果涉及侵權(quán)請(qǐng)盡快告知,我們將會(huì)在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng),如需處理請(qǐng)聯(lián)系客服。電話:028-86922220;郵箱:631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載,或轉(zhuǎn)載時(shí)需注明來(lái)源: 創(chuàng)新互聯(lián)

h5響應(yīng)式網(wǎng)站建設(shè)
主站蜘蛛池模板: 少妇仑乱A毛片无码| 中文字幕精品三区无码亚洲| 无码综合天天久久综合网| 国产成人亚洲精品无码AV大片| JLZZJLZZ亚洲乱熟无码| 麻豆亚洲AV永久无码精品久久| 久久久久无码精品国产h动漫 | 中文字幕乱码无码人妻系列蜜桃| 亚洲中文字幕无码一区二区三区| 亚洲精品av无码喷奶水糖心| 国产精品无码v在线观看| av无码久久久久久不卡网站| 国产亚洲精久久久久久无码AV| 亚洲AV无码久久精品色欲| 日产无码1区2区在线观看 | 免费a级毛片无码av| 日韩爆乳一区二区无码| 九九久久精品无码专区| 无码粉嫩虎白一线天在线观看| 亚洲Av永久无码精品三区在线| 亚洲免费无码在线| 亚洲av无码一区二区三区在线播放| 亚洲国产精品无码专区| 亚洲精品无码激情AV| 国产精品无码一区二区三区在| 精品深夜AV无码一区二区老年| 一本一道av中文字幕无码 | 国产午夜无码片免费| 国产成人无码av在线播放不卡| 无码人妻精品中文字幕免费东京热| 亚洲中文字幕无码爆乳AV| 国产丝袜无码一区二区三区视频 | 国产色无码专区在线观看| 国产嫖妓一区二区三区无码| 亚洲爆乳AAA无码专区| 亚洲AV色无码乱码在线观看| 亚洲AV无码国产精品色| 亚洲最大av资源站无码av网址| 久久亚洲精品成人无码网站| AV无码人妻中文字幕| 天堂一区人妻无码|