Wie löst man Probleme bei der Verwendung von Polling-Sperren in Java?
Problemdemonstration
Wenn wir keine Abfragesperren verwendet haben, kann dieses Problem auftreten:
import java.util.concurrent.locks.Lock; import java.util.concurrent.locks.ReentrantLock; public class DeadLockByReentrantLock { public static void main(String[] args) { Lock lockA = new ReentrantLock(); // 创建锁 A Lock lockB = new ReentrantLock(); // 创建锁 B // 创建线程 1 Thread t1 = new Thread(new Runnable() { @Override public void run() { lockA.lock(); // 加锁 System.out.println("线程 1:获取到锁 A!"); try { Thread.sleep(1000); System.out.println("线程 1:等待获取 B..."); lockB.lock(); // 加锁 try { System.out.println("线程 1:获取到锁 B!"); } finally { lockA.unlock(); // 释放锁 } } catch (InterruptedException e) { e.printStackTrace(); } finally { lockA.unlock(); // 释放锁 } } }); t1.start(); // 运行线程 // 创建线程 2 Thread t2 = new Thread(new Runnable() { @Override public void run() { lockB.lock(); // 加锁 System.out.println("线程 2:获取到锁 B!"); try { Thread.sleep(1000); System.out.println("线程 2:等待获取 A..."); lockA.lock(); // 加锁 try { System.out.println("线程 2:获取到锁 A!"); } finally { lockA.unlock(); // 释放锁 } } catch (InterruptedException e) { e.printStackTrace(); } finally { lockB.unlock(); // 释放锁 } } }); t2.start(); // 运行线程 } }
#🎜🎜 #Die Ausführung Die Ergebnisse des obigen Codes lauten wie folgt:
Die einfache Version der Abfragesperre wird wie folgt implementiert:
import java.util.concurrent.locks.Lock; import java.util.concurrent.locks.ReentrantLock; public class SolveDeadLockExample2 { public static void main(String[] args) { Lock lockA = new ReentrantLock(); // 创建锁 A Lock lockB = new ReentrantLock(); // 创建锁 B // 创建线程 1(使用轮询锁) Thread t1 = new Thread(new Runnable() { @Override public void run() { // 调用轮询锁 pollingLock(lockA, lockB); } }); t1.start(); // 运行线程 // 创建线程 2 Thread t2 = new Thread(new Runnable() { @Override public void run() { lockB.lock(); // 加锁 System.out.println("线程 2:获取到锁 B!"); try { Thread.sleep(1000); System.out.println("线程 2:等待获取 A..."); lockA.lock(); // 加锁 try { System.out.println("线程 2:获取到锁 A!"); } finally { lockA.unlock(); // 释放锁 } } catch (InterruptedException e) { e.printStackTrace(); } finally { lockB.unlock(); // 释放锁 } } }); t2.start(); // 运行线程 } /** * 轮询锁 */ private static void pollingLock(Lock lockA, Lock lockB) { // 轮询锁 while (true) { if (lockA.tryLock()) { // 尝试获取锁 System.out.println("线程 1:获取到锁 A!"); try { Thread.sleep(1000); System.out.println("线程 1:等待获取 B..."); if (lockB.tryLock()) { // 尝试获取锁 try { System.out.println("线程 1:获取到锁 B!"); } finally { lockB.unlock(); // 释放锁 System.out.println("线程 1:释放锁 B."); break; } } } catch (InterruptedException e) { e.printStackTrace(); } finally { lockA.unlock(); // 释放锁 System.out.println("线程 1:释放锁 A."); } } // 等待一秒再继续执行 try { Thread.sleep(1000); } catch (InterruptedException e) { e.printStackTrace(); } } } }
Die Ausführungsergebnisse des obigen Codes sind wie folgt: #🎜🎜 #
Aus den obigen Ergebnissen ist ersichtlich, dass es bei Verwendung der Abfragesperre im Programm kein Deadlock-Problem gibt, in der obigen Runde jedoch Abfragesperren nicht perfekt. Werfen wir einen Blick darauf, welche Probleme diese Wahlsperre haben wird.
Problem 1: Endlosschleife
Die obige einfache Version der Abfragesperre: Wenn es einen Thread gibt, der die Sperrressource belegt oder sie schon lange belegt hat, wird er ausgeführt Dies führt dazu, dass die Abfragesperre in einen Endlosschleifenzustand übergeht. Sie versucht ständig, Sperrressourcen zu erhalten, was zu neuen Problemen und unnötigem Leistungsaufwand führt.
Gegenbeispiel
import java.util.concurrent.locks.Lock; import java.util.concurrent.locks.ReentrantLock; public class SolveDeadLockExample { public static void main(String[] args) { Lock lockA = new ReentrantLock(); // 创建锁 A Lock lockB = new ReentrantLock(); // 创建锁 B // 创建线程 1(使用轮询锁) Thread t1 = new Thread(new Runnable() { @Override public void run() { // 调用轮询锁 pollingLock(lockA, lockB); } }); t1.start(); // 运行线程 // 创建线程 2 Thread t2 = new Thread(new Runnable() { @Override public void run() { lockB.lock(); // 加锁 System.out.println("线程 2:获取到锁 B!"); try { Thread.sleep(1000); System.out.println("线程 2:等待获取 A..."); lockA.lock(); // 加锁 try { System.out.println("线程 2:获取到锁 A!"); } finally { lockA.unlock(); // 释放锁 } } catch (InterruptedException e) { e.printStackTrace(); } finally { // 如果此处代码未执行,线程 2 一直未释放锁资源 // lockB.unlock(); } } }); t2.start(); // 运行线程 } /** * 轮询锁 */ public static void pollingLock(Lock lockA, Lock lockB) { while (true) { if (lockA.tryLock()) { // 尝试获取锁 System.out.println("线程 1:获取到锁 A!"); try { Thread.sleep(1000); System.out.println("线程 1:等待获取 B..."); if (lockB.tryLock()) { // 尝试获取锁 try { System.out.println("线程 1:获取到锁 B!"); } finally { lockB.unlock(); // 释放锁 System.out.println("线程 1:释放锁 B."); break; } } } catch (InterruptedException e) { e.printStackTrace(); } finally { lockA.unlock(); // 释放锁 System.out.println("线程 1:释放锁 A."); } } // 等待一秒再继续执行 try { Thread.sleep(1000); } catch (InterruptedException e) { e.printStackTrace(); } } } }
# 🎜🎜## 🎜🎜#Aus den obigen Ergebnissen ist ersichtlich, dass die Abfragesperre von Thread 1 in einen Endlosschleifenzustand eingetreten ist.
Optimierte Version
Fügen Sie die maximale Anzahl von Malen hinzu:
Wenn die Sperre nach n Versuchen, die Sperre zu erwerben, nicht erworben wurde, wird davon ausgegangen, dass die Sperrenerfassung fehlgeschlagen ist , und die Runde wird nach Ausführung der Fehlerstrategieabfrage beendet (Fehlerstrategie kann Protokollierung oder andere Vorgänge sein); 🎜🎜#Wenn n Sekunden vergangen sind, versuchen Sie, die Sperre zu erhalten. Wenn die Sperre danach nicht erhalten wurde, wird davon ausgegangen, dass die Sperre fehlgeschlagen ist, und die Abfrage wird beendet, nachdem die Fehlerrichtlinie ausgeführt wurde.Jede der oben genannten Strategien kann das Problem der Endlosschleife lösen. Aus Gründen der Implementierungskosten können wir die maximale Anzahl von Umfragen verwenden, um die Abfrage zu verbessern ,
Der spezifische Implementierungscode lautet wie folgt: - Die Ausführungsergebnisse des obigen Codes lauten wie folgt: # 🎜🎜##🎜🎜 #
import java.util.concurrent.locks.Lock; import java.util.concurrent.locks.ReentrantLock; public class SolveDeadLockExample { public static void main(String[] args) { Lock lockA = new ReentrantLock(); // 创建锁 A Lock lockB = new ReentrantLock(); // 创建锁 B // 创建线程 1(使用轮询锁) Thread t1 = new Thread(new Runnable() { @Override public void run() { // 调用轮询锁 pollingLock(lockA, lockB, 3); } }); t1.start(); // 运行线程 // 创建线程 2 Thread t2 = new Thread(new Runnable() { @Override public void run() { lockB.lock(); // 加锁 System.out.println("线程 2:获取到锁 B!"); try { Thread.sleep(1000); System.out.println("线程 2:等待获取 A..."); lockA.lock(); // 加锁 try { System.out.println("线程 2:获取到锁 A!"); } finally { lockA.unlock(); // 释放锁 } } catch (InterruptedException e) { e.printStackTrace(); } finally { // 线程 2 忘记释放锁资源 // lockB.unlock(); // 释放锁 } } }); t2.start(); // 运行线程 } /** * 轮询锁 * * maxCount:最大轮询次数 */ public static void pollingLock(Lock lockA, Lock lockB, int maxCount) { // 轮询次数计数器 int count = 0; while (true) { if (lockA.tryLock()) { // 尝试获取锁 System.out.println("线程 1:获取到锁 A!"); try { Thread.sleep(1000); System.out.println("线程 1:等待获取 B..."); if (lockB.tryLock()) { // 尝试获取锁 try { System.out.println("线程 1:获取到锁 B!"); } finally { lockB.unlock(); // 释放锁 System.out.println("线程 1:释放锁 B."); break; } } } catch (InterruptedException e) { e.printStackTrace(); } finally { lockA.unlock(); // 释放锁 System.out.println("线程 1:释放锁 A."); } } // 判断是否已经超过最大次数限制 if (count++ > maxCount) { // 终止循环 System.out.println("轮询锁获取失败,记录日志或执行其他失败策略"); return; } // 等待一秒再继续尝试获取锁 try { Thread.sleep(1000); } catch (InterruptedException e) { e.printStackTrace(); } } } }
Nach dem Login kopieren
Aus den obigen Ergebnissen ist ersichtlich, dass die Abfragesperre nach der Verbesserung nicht mehr das Problem einer Endlosschleife aufweist bricht die Ausführung nach einer bestimmten Anzahl von Versuchen ab.
Problem 2: Thread-Aushungern
Die Abfragewartezeit unserer oben genannten Abfragesperre ist eine feste Zeit, wie im folgenden Code gezeigt: // 等待 1s 再尝试获取(轮询)锁
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
Gegenbeispiel
import java.util.concurrent.locks.Lock; import java.util.concurrent.locks.ReentrantLock; public class SolveDeadLockExample { public static void main(String[] args) { Lock lockA = new ReentrantLock(); // 创建锁 A Lock lockB = new ReentrantLock(); // 创建锁 B // 创建线程 1(使用轮询锁) Thread t1 = new Thread(new Runnable() { @Override public void run() { // 调用轮询锁 pollingLock(lockA, lockB, 3); } }); t1.start(); // 运行线程 // 创建线程 2 Thread t2 = new Thread(new Runnable() { @Override public void run() { while (true) { lockB.lock(); // 加锁 System.out.println("线程 2:获取到锁 B!"); try { System.out.println("线程 2:等待获取 A..."); lockA.lock(); // 加锁 try { System.out.println("线程 2:获取到锁 A!"); } finally { lockA.unlock(); // 释放锁 } } finally { lockB.unlock(); // 释放锁 } // 等待一秒之后继续执行 try { Thread.sleep(1000); } catch (InterruptedException e) { e.printStackTrace(); } } } }); t2.start(); // 运行线程 } /** * 轮询锁 */ public static void pollingLock(Lock lockA, Lock lockB, int maxCount) { // 循环次数计数器 int count = 0; while (true) { if (lockA.tryLock()) { // 尝试获取锁 System.out.println("线程 1:获取到锁 A!"); try { Thread.sleep(100); // 等待 0.1s(获取锁需要的时间) System.out.println("线程 1:等待获取 B..."); if (lockB.tryLock()) { // 尝试获取锁 try { System.out.println("线程 1:获取到锁 B!"); } finally { lockB.unlock(); // 释放锁 System.out.println("线程 1:释放锁 B."); break; } } } catch (InterruptedException e) { e.printStackTrace(); } finally { lockA.unlock(); // 释放锁 System.out.println("线程 1:释放锁 A."); } } // 判断是否已经超过最大次数限制 if (count++ > maxCount) { // 终止循环 System.out.println("轮询锁获取失败,记录日志或执行其他失败策略"); return; } // 等待一秒再继续尝试获取锁 try { Thread.sleep(1000); } catch (InterruptedException e) { e.printStackTrace(); } } } }
Das Ausführungsergebnis des obigen Codes ist wie folgt:
# 🎜🎜# Aus den obigen Ergebnissen ist ersichtlich, dass Thread 1 (Abfragesperre) die Sperre nie erfolgreich erhalten hat. Der Grund für dieses Ergebnis ist, dass die Wartezeit von Thread 1 für jede Abfrage fest 1s und Thread beträgt 2 hat auch eine feste Wartezeit von 1 Sekunde. Bei der gleichen Häufigkeit wird die Sperre alle 1 Sekunde erworben, was dazu führt, dass Thread 2 die Sperre immer zuerst erfolgreich erhält, während sich Thread 1 immer in einer „Hunger“-Situation befindet 🎜#Der Ausführungsprozess ist wie in der folgenden Abbildung dargestellt: # 🎜🎜#
optimierte Version
Als nächstes werden wir kann die feste Wartezeit der Abrufsperre einstellen, #🎜🎜 #Verbessert auf eine Methode mit fester Zeit + zufälliger Zeit, um das Problem des „Aushungerns“ von Abrufsperren aufgrund der gleichen Häufigkeit des Erwerbs von Sperren zu vermeiden . Der spezifische Implementierungscode lautet wie folgt: #🎜 🎜#
import java.util.Random; import java.util.concurrent.locks.Lock; import java.util.concurrent.locks.ReentrantLock; public class SolveDeadLockExample { private static Random rdm = new Random(); public static void main(String[] args) { Lock lockA = new ReentrantLock(); // 创建锁 A Lock lockB = new ReentrantLock(); // 创建锁 B // 创建线程 1(使用轮询锁) Thread t1 = new Thread(new Runnable() { @Override public void run() { // 调用轮询锁 pollingLock(lockA, lockB, 3); } }); t1.start(); // 运行线程 // 创建线程 2 Thread t2 = new Thread(new Runnable() { @Override public void run() { while (true) { lockB.lock(); // 加锁 System.out.println("线程 2:获取到锁 B!"); try { System.out.println("线程 2:等待获取 A..."); lockA.lock(); // 加锁 try { System.out.println("线程 2:获取到锁 A!"); } finally { lockA.unlock(); // 释放锁 } } finally { lockB.unlock(); // 释放锁 } // 等待一秒之后继续执行 try { Thread.sleep(1000); } catch (InterruptedException e) { e.printStackTrace(); } } } }); t2.start(); // 运行线程 } /** * 轮询锁 */ public static void pollingLock(Lock lockA, Lock lockB, int maxCount) { // 循环次数计数器 int count = 0; while (true) { if (lockA.tryLock()) { // 尝试获取锁 System.out.println("线程 1:获取到锁 A!"); try { Thread.sleep(100); // 等待 0.1s(获取锁需要的时间) System.out.println("线程 1:等待获取 B..."); if (lockB.tryLock()) { // 尝试获取锁 try { System.out.println("线程 1:获取到锁 B!"); } finally { lockB.unlock(); // 释放锁 System.out.println("线程 1:释放锁 B."); break; } } } catch (InterruptedException e) { e.printStackTrace(); } finally { lockA.unlock(); // 释放锁 System.out.println("线程 1:释放锁 A."); } } // 判断是否已经超过最大次数限制 if (count++ > maxCount) { // 终止循环 System.out.println("轮询锁获取失败,记录日志或执行其他失败策略"); return; } // 等待一定时间(固定时间 + 随机时间)之后再继续尝试获取锁 try { Thread.sleep(300 + rdm.nextInt(8) * 100); // 固定时间 + 随机时间 } catch (InterruptedException e) { e.printStackTrace(); } } } }
Die Ausführungsergebnisse des obigen Codes lauten wie folgt:
# 🎜🎜#
Aus den obigen Ergebnissen können Sie erkennen, dass das Problem des Thread-Aushungerns nicht auftritt, nachdem Thread 1 (Abfragesperre) eine zufällige Wartezeit hinzugefügt hat.Das obige ist der detaillierte Inhalt vonWie löst man Probleme bei der Verwendung von Polling-Sperren in Java?. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!

Heiße KI -Werkzeuge

Undresser.AI Undress
KI-gestützte App zum Erstellen realistischer Aktfotos

AI Clothes Remover
Online-KI-Tool zum Entfernen von Kleidung aus Fotos.

Undress AI Tool
Ausziehbilder kostenlos

Clothoff.io
KI-Kleiderentferner

Video Face Swap
Tauschen Sie Gesichter in jedem Video mühelos mit unserem völlig kostenlosen KI-Gesichtstausch-Tool aus!

Heißer Artikel

Heiße Werkzeuge

Notepad++7.3.1
Einfach zu bedienender und kostenloser Code-Editor

SublimeText3 chinesische Version
Chinesische Version, sehr einfach zu bedienen

Senden Sie Studio 13.0.1
Leistungsstarke integrierte PHP-Entwicklungsumgebung

Dreamweaver CS6
Visuelle Webentwicklungstools

SublimeText3 Mac-Version
Codebearbeitungssoftware auf Gottesniveau (SublimeText3)

Heiße Themen











Java 8 führt die Stream -API ein und bietet eine leistungsstarke und ausdrucksstarke Möglichkeit, Datensammlungen zu verarbeiten. Eine häufige Frage bei der Verwendung von Stream lautet jedoch: Wie kann man von einem Foreach -Betrieb brechen oder zurückkehren? Herkömmliche Schleifen ermöglichen eine frühzeitige Unterbrechung oder Rückkehr, aber die Stream's foreach -Methode unterstützt diese Methode nicht direkt. In diesem Artikel werden die Gründe erläutert und alternative Methoden zur Implementierung vorzeitiger Beendigung in Strahlverarbeitungssystemen erforscht. Weitere Lektüre: Java Stream API -Verbesserungen Stream foreach verstehen Die Foreach -Methode ist ein Terminalbetrieb, der einen Vorgang für jedes Element im Stream ausführt. Seine Designabsicht ist

PHP ist eine Skriptsprache, die auf der Serverseite weit verbreitet ist und insbesondere für die Webentwicklung geeignet ist. 1.PHP kann HTML einbetten, HTTP -Anforderungen und Antworten verarbeiten und eine Vielzahl von Datenbanken unterstützt. 2.PHP wird verwendet, um dynamische Webinhalte, Prozessformdaten, Zugriffsdatenbanken usw. mit starker Community -Unterstützung und Open -Source -Ressourcen zu generieren. 3. PHP ist eine interpretierte Sprache, und der Ausführungsprozess umfasst lexikalische Analyse, grammatikalische Analyse, Zusammenstellung und Ausführung. 4.PHP kann mit MySQL für erweiterte Anwendungen wie Benutzerregistrierungssysteme kombiniert werden. 5. Beim Debuggen von PHP können Sie Funktionen wie error_reporting () und var_dump () verwenden. 6. Optimieren Sie den PHP-Code, um Caching-Mechanismen zu verwenden, Datenbankabfragen zu optimieren und integrierte Funktionen zu verwenden. 7

PHP und Python haben jeweils ihre eigenen Vorteile, und die Wahl sollte auf Projektanforderungen beruhen. 1.PHP eignet sich für die Webentwicklung mit einfacher Syntax und hoher Ausführungseffizienz. 2. Python eignet sich für Datenwissenschaft und maschinelles Lernen mit präziser Syntax und reichhaltigen Bibliotheken.

PHP eignet sich für die Webentwicklung, insbesondere für die schnelle Entwicklung und Verarbeitung dynamischer Inhalte, ist jedoch nicht gut in Anwendungen auf Datenwissenschaft und Unternehmensebene. Im Vergleich zu Python hat PHP mehr Vorteile in der Webentwicklung, ist aber nicht so gut wie Python im Bereich der Datenwissenschaft. Im Vergleich zu Java wird PHP in Anwendungen auf Unternehmensebene schlechter, ist jedoch flexibler in der Webentwicklung. Im Vergleich zu JavaScript ist PHP in der Back-End-Entwicklung präziser, ist jedoch in der Front-End-Entwicklung nicht so gut wie JavaScript.

PHP und Python haben jeweils ihre eigenen Vorteile und eignen sich für verschiedene Szenarien. 1.PHP ist für die Webentwicklung geeignet und bietet integrierte Webserver und reichhaltige Funktionsbibliotheken. 2. Python eignet sich für Datenwissenschaft und maschinelles Lernen mit prägnanter Syntax und einer leistungsstarken Standardbibliothek. Bei der Auswahl sollte anhand der Projektanforderungen festgelegt werden.

Kapseln sind dreidimensionale geometrische Figuren, die aus einem Zylinder und einer Hemisphäre an beiden Enden bestehen. Das Volumen der Kapsel kann berechnet werden, indem das Volumen des Zylinders und das Volumen der Hemisphäre an beiden Enden hinzugefügt werden. In diesem Tutorial wird erörtert, wie das Volumen einer bestimmten Kapsel in Java mit verschiedenen Methoden berechnet wird. Kapselvolumenformel Die Formel für das Kapselvolumen lautet wie folgt: Kapselvolumen = zylindrisches Volumenvolumen Zwei Hemisphäre Volumen In, R: Der Radius der Hemisphäre. H: Die Höhe des Zylinders (ohne die Hemisphäre). Beispiel 1 eingeben Radius = 5 Einheiten Höhe = 10 Einheiten Ausgabe Volumen = 1570,8 Kubikeinheiten erklären Berechnen Sie das Volumen mithilfe der Formel: Volumen = π × R2 × H (4

PhPhas significantantyPactedWebDevelopmentAndendendsbeyondit.1) iTpowersMAjorPlatforms-LikewordpressandExcelsInDatabaseInteractions.2) php'SadaptabilityAllowStoscaleForLargeApplicationsfraMe-Linien-Linien-Linien-Linienkripte

Die Gründe, warum PHP für viele Websites der bevorzugte Technologie -Stack ist, umfassen die Benutzerfreundlichkeit, die starke Unterstützung der Community und die weit verbreitete Verwendung. 1) Einfach zu erlernen und zu bedienen, geeignet für Anfänger. 2) eine riesige Entwicklergemeinschaft und eine reichhaltige Ressourcen haben. 3) in WordPress, Drupal und anderen Plattformen häufig verwendet. 4) Integrieren Sie eng in Webserver, um die Entwicklung der Entwicklung zu vereinfachen.
