首頁 > 軟體

Java多執行緒run方法中直接呼叫service業務類應注意的問題及解決

2022-06-21 14:03:01

多執行緒run方法中直接呼叫service業務類應注意

Java多執行緒run方法裡邊使用service業務類會產生java.lang.NullPointerException異常的問題,這是由於spring注入的業務類為null,或者直接new的業務物件也為null。

多執行緒為了執行緒安全會防止注入,因此在想使用service業務類時,需要使用ApplicationContext的方式獲取bean的方法獲取service類。

獲取ApplicationContext的類要實現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方法裡使用以上方法建立業務物件,如下:

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

這樣就能正常使用該業務類了。

圖解如下

多執行緒知識點

執行緒啟動的四種方式

1.、繼承Thread類重寫Thread的run方法,在run方法中進行操作,用start方法啟動執行緒

2、繼承Runnable介面,實現run方法,在run方法中進行操作,需要傳入當前類的範例物件建立一個Thread範例,然後呼叫start方法啟動執行緒

3、實現Callable介面,重寫call()方法,需要注意的是,前兩種方法都是不需要響應的,直接就執行了,但是實現Callable介面,重寫call()方法則是需要等待執行緒響應的,所以雖然啟動了其他執行緒,但是卻是一個執行緒在執行,並不能算標準的多執行緒。

4、執行緒池

使用@Aysnc註解實現多執行緒

同一個類中,方法A 參照方法B 方法B加非同步@Async註解 不會有效

被加@Async方法和呼叫方 不能再同一個類中

使用者執行緒與守護執行緒的區別

Java內建立的執行緒預設是建立使用者執行緒,比如new Thread(執行緒物件).start

    Thread thread = new Thread();
    // 預設為false,都是使用者執行緒
    thread.setDaemon(true); // 表示設定為守護執行緒
    thread.setDaemon(false); // 表示設定為使用者執行緒
  • 使用者執行緒:不zhi隨著其他執行緒的死亡而死亡,只有兩種情況dao死掉,一是在執行中出現異常而終止,二是正常把程式執行完畢,執行緒死亡
  • 守護執行緒:隨著使用者執行緒的死亡而死亡,當用戶執行緒死完了守護執行緒也死了,比如gc垃圾回收執行緒。使用者執行緒存在,那gc就有活著的必要,反之就沒用了。

執行緒的六種狀態

1. New:初始狀態,執行緒被建立,沒有呼叫start()

2. Runnable:執行狀態,Java執行緒把作業系統中的就緒和執行兩種狀態統一稱為“執行中”

3. Blocked:阻塞,執行緒進入等待狀態,執行緒因為某種原因,放棄了CPU的使用權

  • 阻塞的幾種情況:
  • A. 等待阻塞:執行的執行緒執行了wait(),JVM會把當前執行緒放入等待佇列
  • B. 同步阻塞:執行的執行緒在獲取物件的同步鎖時,如果該同步鎖被其他執行緒佔用了,JVM會把當前執行緒放入鎖池中
  • C. 其他阻塞:執行的執行緒執行sleep(),join()或者發出IO請求時,JVM會把當前執行緒設定為阻塞狀態,當sleep()執行完,join()執行緒終止,IO處理完畢執行緒再次恢復

4. Waiting:等待狀態

5. timed_waiting:超時等待狀態,超時以後自動返回

6. terminated:終止狀態,當前執行緒執行完畢

Java鎖的可重入性

java鎖的可重入性機制可以解決下面這個問題,直接上程式碼:

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

假設Java沒有提供synchronized 強制原子性的內部鎖機制:functionA()和functionB()都是同步方法,當執行緒進入funcitonA()會獲得該類的物件鎖,這個鎖"new Demo1()",在functionA()對方法functionB()做了呼叫,但是functionB()也是同步的,因此該執行緒需要再次獲得該物件鎖(new Demo1()),但是JVM會認為這個執行緒已經獲取了此物件的鎖,而不能再次獲取,從而無法呼叫functionB()方法,從而造成死鎖。

執行緒池的四種拒絕策略

當執行緒池的任務快取佇列已滿並且執行緒池中的執行緒數目達到maximumPoolSize時,如果還有任務到來就會採取任務拒絕策略,通常有以下四種策略:

ThreadPoolExecutor.AbortPolicy:丟棄任務並丟擲RejectedExecutionException異常。

ThreadPoolExecutor.DiscardPolicy:丟棄任務,但是不丟擲異常。

ThreadPoolExecutor.DiscardOldestPolicy:丟棄佇列最前面的任務,然後重新提交被拒絕的任務

ThreadPoolExecutor.CallerRunsPolicy:由呼叫執行緒(提交任務的執行緒)處理該任務

sleep和wait的區別

  • sleep是執行緒中的方法,但是wait是Object中的方法
  • sleep方法不會釋放lock,但是wait會釋放,而且會加入到等待佇列中
  • sleep不需要被喚醒,但是wait需要

為什麼wait(),notify(),notifyAll()在物件中,而不在Thread類中

java中鎖的級別是物件級而不是執行緒級,每個物件都有鎖,通過執行緒獲得。如果wait()方法線上程中,執行緒正在等待的是哪個鎖就不明顯了。

以上為個人經驗,希望能給大家一個參考,也希望大家多多支援it145.com。


IT145.com E-mail:sddin#qq.com