Exemples d'implémentation de files d'attente de messages multithread en Java

Cet article présente principalement le code d'implémentation de la file d'attente de messages multithread Java. L'éditeur pense que c'est assez bon. Maintenant, je vais le partager avec vous et le donner comme référence. Suivons l'éditeur et jetons un coup d'œil

Cet article présente le code d'implémentation de la file d'attente de messages multithread Java. Je le partage avec vous. J'espère qu'il sera utile à tout le monde. pour vous-même

1. Définissez un pool de tampons de file d'attente :

 //static修饰的成员变量和成员方法独立于该类的任何对象。也就是说，它不依赖类特定的实例，被类的所有实例共享。
private static List<Queue> queueCache = new LinkedList<Queue>();

2. Si cette valeur est atteinte, l'enregistrement dans la file d'attente attendra le retrait Continuer en dessous de cette valeur.

private Integer offerMaxQueue = 2000;

3. Définissez le fil de paiement. S'il n'y a aucun message dans le pool de tampons de file d'attente, le fil de paiement attendra

<🎜. >

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();

4. File d'attente d'enregistrement

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
}

5. Implémentation de la méthode de verrouillage

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!