多線程run方法中直接調(diào)用service業(yè)務(wù)類應(yīng)注意

Java多線程run方法里邊使用service業(yè)務(wù)類會產(chǎn)生java.lang.NullPointerException異常的問題，這是由于spring注入的業(yè)務(wù)類為null，或者直接new的業(yè)務(wù)對象也為null。

多線程為了線程安全會防止注入，因此在想使用service業(yè)務(wù)類時，需要使用ApplicationContext的方式獲取bean的方法獲取service類。

獲取ApplicationContext的類要實(shí)現(xiàn)ApplicationContextAware接口，如下：

import org.springframework.beans.BeansException;
import org.springframework.context.ApplicationContext;
import org.springframework.context.ApplicationContextAware;
 
public class ApplicationContextUtil implements ApplicationContextAware {
	private static ApplicationContext context;
	public void setApplicationContext(ApplicationContext context) throws BeansException {
		this.context = context;
	}
	public static ApplicationContext getContext() {
		return context;
	}
}

然后在run方法里使用以上方法創(chuàng)建業(yè)務(wù)對象，如下：

XXXServiceI xxxService = ApplicationContextUtil.getContext.getBean(XXXServiceI.class);

這樣就能正常使用該業(yè)務(wù)類了。

圖解如下

多線程知識點(diǎn)

線程啟動的四種方式

1.、繼承Thread類重寫Thread的run方法，在run方法中進(jìn)行操作，用start方法啟動線程

2、繼承Runnable接口，實(shí)現(xiàn)run方法，在run方法中進(jìn)行操作，需要傳入當(dāng)前類的實(shí)例對象創(chuàng)建一個Thread實(shí)例，然后調(diào)用start方法啟動線程

3、實(shí)現(xiàn)Callable接口，重寫call()方法，需要注意的是，前兩種方法都是不需要響應(yīng)的，直接就執(zhí)行了，但是實(shí)現(xiàn)Callable接口，重寫call()方法則是需要等待線程響應(yīng)的，所以雖然啟動了其他線程，但是卻是一個線程在執(zhí)行，并不能算標(biāo)準(zhǔn)的多線程。

4、線程池

使用@Aysnc注解實(shí)現(xiàn)多線程

同一個類中，方法A 引用方法B 方法B加異步@Async注解 不會有效

被加@Async方法和調(diào)用方 不能再同一個類中

用戶線程與守護(hù)線程的區(qū)別

Java內(nèi)創(chuàng)建的線程默認(rèn)是創(chuàng)建用戶線程，比如new Thread(線程對象).start

    Thread thread = new Thread();
    // 默認(rèn)為false，都是用戶線程
    thread.setDaemon(true); // 表示設(shè)置為守護(hù)線程
    thread.setDaemon(false); // 表示設(shè)置為用戶線程

• 用戶線程：不zhi隨著其他線程的死亡而死亡，只有兩種情況dao死掉，一是在運(yùn)行中出現(xiàn)異常而終止，二是正常把程序執(zhí)行完畢，線程死亡
• 守護(hù)線程：隨著用戶線程的死亡而死亡，當(dāng)用戶線程死完了守護(hù)線程也死了，比如gc垃圾回收線程。用戶線程存在，那gc就有活著的必要，反之就沒用了。

線程的六種狀態(tài)

1. New:初始狀態(tài)，線程被創(chuàng)建，沒有調(diào)用start（）

2. Runnable:運(yùn)行狀態(tài)，Java線程把操作系統(tǒng)中的就緒和運(yùn)行兩種狀態(tài)統(tǒng)一稱為“運(yùn)行中”

3. Blocked:阻塞，線程進(jìn)入等待狀態(tài)，線程因?yàn)槟撤N原因，放棄了CPU的使用權(quán)

• 阻塞的幾種情況：
• A. 等待阻塞：運(yùn)行的線程執(zhí)行了wait()，JVM會把當(dāng)前線程放入等待隊列
• B. 同步阻塞：運(yùn)行的線程在獲取對象的同步鎖時，如果該同步鎖被其他線程占用了，JVM會把當(dāng)前線程放入鎖池中
• C. 其他阻塞：運(yùn)行的線程執(zhí)行sleep(),join()或者發(fā)出IO請求時，JVM會把當(dāng)前線程設(shè)置為阻塞狀態(tài)，當(dāng)sleep()執(zhí)行完，join()線程終止，IO處理完畢線程再次恢復(fù)

4. Waiting:等待狀態(tài)

5. timed_waiting:超時等待狀態(tài)，超時以后自動返回

6. terminated:終止?fàn)顟B(tài)，當(dāng)前線程執(zhí)行完畢

Java鎖的可重入性

java鎖的可重入性機(jī)制可以解決下面這個問題,直接上代碼：

 public class Demo1 {
    public synchronized void functionA(){
        System.out.println("iAmFunctionA");
        functionB();
    }
    public synchronized void functionB(){
        System.out.println("iAmFunctionB");
    }

假設(shè)Java沒有提供synchronized 強(qiáng)制原子性的內(nèi)部鎖機(jī)制：functionA()和functionB()都是同步方法，當(dāng)線程進(jìn)入funcitonA()會獲得該類的對象鎖，這個鎖"new Demo1()"，在functionA()對方法functionB()做了調(diào)用，但是functionB()也是同步的，因此該線程需要再次獲得該對象鎖（new Demo1()），但是JVM會認(rèn)為這個線程已經(jīng)獲取了此對象的鎖，而不能再次獲取，從而無法調(diào)用functionB()方法，從而造成死鎖。

線程池的四種拒絕策略

當(dāng)線程池的任務(wù)緩存隊列已滿并且線程池中的線程數(shù)目達(dá)到maximumPoolSize時，如果還有任務(wù)到來就會采取任務(wù)拒絕策略，通常有以下四種策略：

ThreadPoolExecutor.AbortPolicy：丟棄任務(wù)并拋出RejectedExecutionException異常。

ThreadPoolExecutor.DiscardPolicy：丟棄任務(wù)，但是不拋出異常。

ThreadPoolExecutor.DiscardOldestPolicy：丟棄隊列最前面的任務(wù)，然后重新提交被拒絕的任務(wù)

ThreadPoolExecutor.CallerRunsPolicy：由調(diào)用線程（提交任務(wù)的線程）處理該任務(wù)

sleep和wait的區(qū)別

• sleep是線程中的方法，但是wait是Object中的方法
• sleep方法不會釋放lock，但是wait會釋放，而且會加入到等待隊列中
• sleep不需要被喚醒，但是wait需要

為什么wait()，notify()，notifyAll()在對象中，而不在Thread類中

java中鎖的級別是對象級而不是線程級，每個對象都有鎖，通過線程獲得。如果wait()方法在線程中，線程正在等待的是哪個鎖就不明顯了。

以上為個人經(jīng)驗(yàn)，希望能給大家一個參考，也希望大家多多支持腳本之家。

最新評論