Die Verwendung der Service-Business-Klasse in der Java-Multithread-Ausführungsmethode führt zu einer java.lang.NullPointerException-Ausnahme. Dies liegt an der Business-Klasse Von Spring injiziert ist null oder direkt new Das Geschäftsobjekt ist ebenfalls null.
Multithreading verhindert die Injektion aus Gründen der Thread-Sicherheit. Wenn Sie also die Service-Business-Klasse verwenden möchten, müssen Sie die ApplicationContext-Methode verwenden, um die Bean-Methode zum Abrufen der Service-Klasse abzurufen.
Um die ApplicationContext-Klasse zu erhalten, müssen Sie die ApplicationContextAware-Schnittstelle wie folgt implementieren:
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; } }
Verwenden Sie dann die obige Methode in der Ausführungsmethode, um ein Geschäftsobjekt wie folgt zu erstellen:
XXXServiceI xxxService = ApplicationContextUtil.getContext.getBean(XXXServiceI.class);
Auf diese Weise können Sie verwenden normalerweise die Business Class.
1. Erben Sie die Thread-Klasse, schreiben Sie die Ausführungsmethode von Thread neu und arbeiten Sie in der run-Methode, verwenden Sie die Startmethode, um den Thread zu starten.
2. Erben Sie die Runnable-Schnittstelle, implementieren Sie die run-Methode und führen Sie den Betrieb in der run-Methode aus. Sie müssen das Instanzobjekt der aktuellen Klasse übergeben, um einen Thread zu erstellen Instanz, und rufen Sie dann die Startmethode auf, um den Thread zu starten
3. Implementieren Sie die Callable-Schnittstelle und schreiben Sie die call()-Methode neu. Es ist zu beachten, dass die ersten beiden Methoden keine Antwort erfordern und direkt ausgeführt werden. Die Implementierung der Callable-Schnittstelle und das Umschreiben der call()-Methode erfordert jedoch das Warten auf den Responsive-Thread. Obwohl andere Threads gestartet werden, wird ein Thread ausgeführt, was nicht als Standard-Multithreading angesehen werden kann.
4. Thread-Pool
Der Unterschied zwischen Benutzer-Threads und Daemon-Threads. In Java erstellte Threads erstellen standardmäßig Benutzer-Threads, z. B. einen neuen Thread (Thread-Objekt).start
Benutzerthread: Wenn der Benutzer-Thread stirbt, stirbt auch der Daemon-Thread, z. B. der GC-Garbage-Collection-Thread. Wenn der Benutzerthread vorhanden ist, muss gc aktiv sein, sonst ist er nutzlos. 🔜 System Wird als „running“ bezeichnet3. Blockiert, der Thread geht in den Wartezustand über und der Thread gibt aus irgendeinem Grund das Recht auf, die CPU zu verwenden zum Blockieren: Wenn der laufende Thread wait() ausführt, stellt die JVM den aktuellen Thread in die Warteschlange. Synchronisationsblockierung: Wenn der laufende Thread die Synchronisationssperre des Objekts erhält, wenn die Synchronisationssperre belegt ist Durch andere Threads stellt die JVM den aktuellen Thread in den Sperrpool Wenn der Blockierungsstatus abgeschlossen ist, wird der Join()-Thread beendet und der Thread wird nach Abschluss der E/A-Verarbeitung wieder aufgenommen
4 Warten: Wartestatus5 kehrt nach Zeitüberschreitung zurück
Der Wiedereintrittsmechanismus von Java-Sperren kann das folgende Problem direkt im Code lösen:
Thread thread = new Thread(); // 默认为false,都是用户线程 thread.setDaemon(true); // 表示设置为守护线程 thread.setDaemon(false); // 表示设置为用户线程
Angenommen, Java tut dies Bietet keine synchronisierten internen Sperrmechanismen, die Atomizität erzwingen: FunktionA () und FunktionB () sind alle synchrone Methoden. Wenn der Thread funcitonA () eingibt, erhält er die Objektsperre dieser Klasse. In functionA() wird die Methode functionB() aufgerufen, aber functionB() ist ebenfalls synchron, sodass der Thread die Objektsperre (neue Demo1()) erneut erwerben muss, die JVM jedoch davon ausgeht, dass dieser Thread die erhalten hat Sperre dieses Objekts und kann es nicht erneut abrufen, daher kann die Methode functionB() nicht aufgerufen werden, was zu einem Deadlock führt.
Wenn die Task-Cache-Warteschlange des Thread-Pools voll ist und die Anzahl der Threads im Thread-Pool die maximale Poolgröße erreicht, wird die Task-Ablehnungsstrategie übernommen, wenn noch Aufgaben eintreffen normalerweise vier Strategien:
ThreadPoolExecutor.AbortPolicy
: Die Aufgabe verwerfen und eine RejectedExecutionException auslösen. ThreadPoolExecutor.AbortPolicy
:丢弃任务并抛出RejectedExecutionException异常。
ThreadPoolExecutor.DiscardPolicy
:丢弃任务,但是不抛出异常。
ThreadPoolExecutor.DiscardOldestPolicy
:丢弃队列最前面的任务,然后重新提交被拒绝的任务
ThreadPoolExecutor.CallerRunsPolicy
ThreadPoolExecutor.DiscardPolicy
: Die Aufgabe verwerfen, aber keine Ausnahme auslösen.
ThreadPoolExecutor.DiscardOldestPolicy
: Die vorderste Aufgabe der Warteschlange verwerfen und dann die abgelehnte Aufgabe erneut senden ThreadPoolExecutor.CallerRunsPolicy
: Wird vom aufrufenden Thread (dem Thread, der übermittelt hat) verarbeitet die Aufgabe) Diese AufgabeDer Unterschied zwischen Schlaf und WartenDas obige ist der detaillierte Inhalt vonSo rufen Sie die Service-Business-Klasse direkt in der Java-Multithread-Ausführungsmethode auf. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!