Maison Java javaDidacticiel Explication détaillée des exemples de file d'attente de blocage BlockingQueue en Java

Explication détaillée des exemples de file d'attente de blocage BlockingQueue en Java

Apr 27, 2017 am 09:37 AM
java

Cet article présente principalement l'explication détaillée et des exemples de file d'attente de blocage BlockingQueue en Java. Les amis qui en ont besoin peuvent se référer à

Explication détaillée et exemples de file d'attente de blocage BlockingQueue en Java

BlockingQueue est une bonne solution pour la transmission de données en multi-threads Tout d'abord, BlockingQueue est une interface qui comporte environ quatre classes d'implémentation. C'est une file d'attente très particulière. Si la BlockQueue est vide, l'opération. d'obtenir des éléments de BlockingQueue sera bloqué et entrera dans l'état d'attente, et ne sera pas réveillé tant que BlockingQueue ne contiendra pas quelque chose. De même, si BlockingQueue est pleine, toute opération qui tente d'y stocker quelque chose sera également bloquée. et entre dans l'état d'attente, et ne sera pas réveillé tant qu'il n'y aura pas d'espace dans BlockingQueue pour continuer l'opération.

Quatre classes d'implémentation de BlockingQueue :

1.ArrayBlockingQueue : BlockingQueue avec une taille spécifiée. Son constructeur doit prendre un paramètre int pour indiquer sa taille. Il contient les objets. sont triés dans l'ordre FIFO (premier entré, premier sorti)


2. LinkedBlockingQueue : BlockingQueue de taille variable Si son constructeur prend un paramètre avec une taille spécifiée, la BlockingQueue générée a une limite de taille. S'il n'y a pas de paramètre de taille, la taille de la BlockingQueue générée est déterminée par Integer.MAX_VALUE. Les objets qu'elle contient sont triés dans l'ordre FIFO (premier entré, premier sorti)


3.PriorityBlockingQueue : similaire. à LinkedBlockQueue, mais le tri des objets qu'il contient n'est pas FIFO, mais basé sur l'ordre de tri naturel des objets ou l'ordre déterminé par le Comparator du constructeur


4.SynchronousQueue : a. BlockingQueue spécial, pour lequel l'opération doit être complétée alternativement en mettant et en prenant

Méthodes courantes de BlockingQueue :

1) add(anObject) : ajouter un objet au. BlockingQueue, c'est-à-dire si le BlockingQueue S'il peut être pris en charge, renvoie true, sinon une exception sera signalée


2) offer(anObject) : indique que si possible, ajoutez un objet au BlockingQueue, c'est-à-dire que si BlockingQueue peut l'accepter, retournez true, sinon retournez false


3)put(anObject) : ajoutez un objet à BlockingQueue Si BlockQueue n'a pas d'espace, le thread qui l'appelle. La méthode sera bloquée jusqu'à ce qu'il y ait de l'espace dans BlockingQueue avant de continuer


4)poll(time) : supprimez le premier objet dans BlockingQueue S'il ne peut pas être retiré immédiatement, vous pouvez attendre. pour le temps spécifié par le paramètre time. S'il ne peut pas être retiré, retournez null


5)take() : prend le premier objet dans BlockingQueue. Si BlockingQueue est vide, le bloc le fera. entrez dans l'état d'attente jusqu'à ce que de nouveaux objets soient ajoutés au blocage

Exemple :

Cet exemple simule principalement le flux de travail entre les producteurs et les consommateurs. attendre que les producteurs produisent des produits que les consommateurs puissent consommer.

Producteur :

package com.gefufeng;
import java.util.concurrent.BlockingQueue;

public class Producter implements Runnable{
 private BlockingQueue<String> blockingQueue;
 
 public Producter(BlockingQueue<String> blockingQueue){
 this.blockingQueue = blockingQueue;
 }

 @Override
 public void run() {
 try {
  blockingQueue.put("我生产的" + Thread.currentThread().getName());
  System.out.println("我生产的" + Thread.currentThread().getName());
 } catch (InterruptedException e) {
  // TODO Auto-generated catch block
  e.printStackTrace();
  System.out.println("生产失败");
     }
 }
}
Copier après la connexion

Consommateur :

package com.gefufeng;
import java.util.concurrent.BlockingQueue;
public class Customer implements Runnable{
 private BlockingQueue<String> blockingQueue;
 public Customer(BlockingQueue<String> blockingQueue){
 this.blockingQueue = blockingQueue;
 }
 @Override
 public void run() {
 for(;;){
  try {
  String threadName = blockingQueue.take();
  System.out.println("取出:" + threadName);
  } catch (InterruptedException e) {
  // TODO Auto-generated catch block
  e.printStackTrace();
  System.out.println("取出失败");
  }
 }
 }
}
Copier après la connexion
Classe d'exécution :

package com.gefufeng;
import java.util.concurrent.ArrayBlockingQueue;
public class Executer {
 public static void main(String[] args) {
 ArrayBlockingQueue<String> arrayBlockingQueue = new ArrayBlockingQueue<String>(2);
 Producter producter = new Producter(arrayBlockingQueue);
 Customer cusotmer = new Customer(arrayBlockingQueue);
 new Thread(cusotmer).start();
 for(;;){
  try {
  Thread.sleep(2000);
  new Thread(producter).start();
  } catch (InterruptedException e) {
  // TODO Auto-generated catch block
  e.printStackTrace();
  }
 }
 }
}
Copier après la connexion
Le premier est le consommateur attend le produit dans une boucle. Lorsque blockingQueue.take() est exécuté pour la première fois dans la boucle, aucun produit ne peut être obtenu, il entre donc dans l'état de blocage deux secondes plus tard, le producteur produit un produit, donc blockingQueue. récupère le produit et l'imprime.Après avoir lu le journal, le consommateur a exécuté la deuxième boucle et a constaté que blockingQueue.take() n'avait pas récupéré le produit, il est donc entré à nouveau dans l'état de blocage. . . Parcourez

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!

Déclaration de ce site Web
Le contenu de cet article est volontairement contribué par les internautes et les droits d'auteur appartiennent à l'auteur original. Ce site n'assume aucune responsabilité légale correspondante. Si vous trouvez un contenu suspecté de plagiat ou de contrefaçon, veuillez contacter admin@php.cn

Outils d'IA chauds

Undresser.AI Undress

Undresser.AI Undress

Application basée sur l'IA pour créer des photos de nu réalistes

AI Clothes Remover

AI Clothes Remover

Outil d'IA en ligne pour supprimer les vêtements des photos.

Undress AI Tool

Undress AI Tool

Images de déshabillage gratuites

Clothoff.io

Clothoff.io

Dissolvant de vêtements AI

AI Hentai Generator

AI Hentai Generator

Générez AI Hentai gratuitement.

Article chaud

R.E.P.O. Crystals d'énergie expliqués et ce qu'ils font (cristal jaune)
2 Il y a quelques semaines By 尊渡假赌尊渡假赌尊渡假赌
Repo: Comment relancer ses coéquipiers
4 Il y a quelques semaines By 尊渡假赌尊渡假赌尊渡假赌
Hello Kitty Island Adventure: Comment obtenir des graines géantes
4 Il y a quelques semaines By 尊渡假赌尊渡假赌尊渡假赌
Combien de temps faut-il pour battre Split Fiction?
3 Il y a quelques semaines By DDD

Outils chauds

Bloc-notes++7.3.1

Bloc-notes++7.3.1

Éditeur de code facile à utiliser et gratuit

SublimeText3 version chinoise

SublimeText3 version chinoise

Version chinoise, très simple à utiliser

Envoyer Studio 13.0.1

Envoyer Studio 13.0.1

Puissant environnement de développement intégré PHP

Dreamweaver CS6

Dreamweaver CS6

Outils de développement Web visuel

SublimeText3 version Mac

SublimeText3 version Mac

Logiciel d'édition de code au niveau de Dieu (SublimeText3)

Racine carrée en Java Racine carrée en Java Aug 30, 2024 pm 04:26 PM

Guide de la racine carrée en Java. Nous discutons ici du fonctionnement de Square Root en Java avec un exemple et son implémentation de code respectivement.

Nombre parfait en Java Nombre parfait en Java Aug 30, 2024 pm 04:28 PM

Guide du nombre parfait en Java. Nous discutons ici de la définition, comment vérifier le nombre parfait en Java ?, des exemples d'implémentation de code.

Générateur de nombres aléatoires en Java Générateur de nombres aléatoires en Java Aug 30, 2024 pm 04:27 PM

Guide du générateur de nombres aléatoires en Java. Nous discutons ici des fonctions en Java avec des exemples et de deux générateurs différents avec d'autres exemples.

Weka en Java Weka en Java Aug 30, 2024 pm 04:28 PM

Guide de Weka en Java. Nous discutons ici de l'introduction, de la façon d'utiliser Weka Java, du type de plate-forme et des avantages avec des exemples.

Numéro Armstrong en Java Numéro Armstrong en Java Aug 30, 2024 pm 04:26 PM

Guide du numéro Armstrong en Java. Nous discutons ici d'une introduction au numéro d'Armstrong en Java ainsi que d'une partie du code.

Numéro de Smith en Java Numéro de Smith en Java Aug 30, 2024 pm 04:28 PM

Guide du nombre de Smith en Java. Nous discutons ici de la définition, comment vérifier le numéro Smith en Java ? exemple avec implémentation de code.

Questions d'entretien chez Java Spring Questions d'entretien chez Java Spring Aug 30, 2024 pm 04:29 PM

Dans cet article, nous avons conservé les questions d'entretien Java Spring les plus posées avec leurs réponses détaillées. Pour que vous puissiez réussir l'interview.

Break or Return of Java 8 Stream Forach? Break or Return of Java 8 Stream Forach? Feb 07, 2025 pm 12:09 PM

Java 8 présente l'API Stream, fournissant un moyen puissant et expressif de traiter les collections de données. Cependant, une question courante lors de l'utilisation du flux est: comment se casser ou revenir d'une opération FOREAK? Les boucles traditionnelles permettent une interruption ou un retour précoce, mais la méthode Foreach de Stream ne prend pas directement en charge cette méthode. Cet article expliquera les raisons et explorera des méthodes alternatives pour la mise en œuvre de terminaison prématurée dans les systèmes de traitement de flux. Lire plus approfondie: Améliorations de l'API Java Stream Comprendre le flux Forach La méthode foreach est une opération terminale qui effectue une opération sur chaque élément du flux. Son intention de conception est

See all articles