Heim >Java >javaLernprogramm >Beispiele für die Implementierung von Multithread-Nachrichtenwarteschlangen in Java
In diesem Artikel wird hauptsächlich der Implementierungscode der Java-Multithread-Nachrichtenwarteschlange vorgestellt. Jetzt werde ich ihn mit Ihnen teilen und als Referenz verwenden. Schauen wir uns den Editor an.
Dieser Artikel stellt den Implementierungscode der Java-Multithread-Nachrichtenwarteschlange vor. Ich hoffe, dass er für alle hilfreich ist für sich selbst
1. Definieren Sie einen Warteschlangenpufferpool:
//static修饰的成员变量和成员方法独立于该类的任何对象。也就是说,它不依赖类特定的实例,被类的所有实例共享。 private static List<Queue> queueCache = new LinkedList<Queue>();
2. Definieren Sie die maximale Anzahl von Nachrichten im Warteschlangenpufferpool . Wenn dieser Wert erreicht ist, wartet die Check-in-Warteschlange auf den Check-out. Fahren Sie unterhalb dieses Werts fort.
private Integer offerMaxQueue = 2000;
3. Definieren Sie den Checkout-Thread. Wenn sich keine Nachricht im Warteschlangenpufferpool befindet, wartet der Checkout-Thread >
4. Check-in-Warteschlange
new Thread(){ public void run(){ while(true){ String ip = null; try { synchronized (queueCache) { Integer size = queueCache.size(); if(size==0){ //队列缓存池没有消息,等待。。。。 queueCache.wait(); } Queue queue = queueCache.remove(0); if(isIpLock(queueStr)){//假若这个是一个多应用的分布式系统,那么这个判断应该是分布式锁,这里说的锁不是线程停止,而是跳过该消息,滞后处理 queueCache.add(queue);该queue重新加入队列缓冲池,滞后处理, continue; }else{ ;//这里是处理该消息的操作。 } size = queueCache.size(); if(size<offerMaxQueue&&size>=0){ queueCache.notifyAll();//在队列缓存池不超过最大值的前提下,假若检入正在等待中,那么那么让他们排队检入。 } } } catch (Exception e) { e.printStackTrace(); }finally{ try {//检出该消息队列的锁 unIpLock(queueStr); } catch (Execption e) {//捕获异常,不能让线程挂掉 e.printStackTrace(); } } } }.start();
5. Implementierung der Sperrmethode
synchronized (queueCache) { while(true){ Integer size = queueCache.size(); if(size>=offerMaxQueue){ try { queueCache.wait(); continue;//继续执行等待中的检入任务。 } catch (InterruptedException e) { e.printStackTrace(); } }//IF if(size<=offerMaxQueue&&size>0){ queueCache.notifyAll(); } break;//检入完毕 }//while }
Das obige ist der detaillierte Inhalt vonBeispiele für die Implementierung von Multithread-Nachrichtenwarteschlangen in Java. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!