Qu'est-ce que SynchronousQueue en Java

Description de la fonction

Pour comprendre SynchronousQueue, vous devez d'abord connaître sa fonction. Ce n'est qu'en connaissant le but de cette classe et les fonctions qu'elle fournit que vous pourrez ne pas vous perdre lors de la lecture du code source.

Dans notre étude précédente, si des threads souhaitent échanger des données, ils utilisent généralement une variable publique ou une file d'attente de blocage synchrone. Le thread producteur définit la variable ou met la valeur dans la file d'attente, et le thread consommateur lit la variable ou prend. de la file d'attente.

Le SynchronousQueue n'a pas besoin de stocker les données échangées entre les threads. Il fonctionne plutôt comme un matcher pour faire correspondre les producteurs et les consommateurs un par un.

Processus général

Par exemple, lorsqu'un thread appelle la méthode put et constate qu'il n'y a pas de thread de prise dans la file d'attente, le thread de mise sera bloqué lorsque le thread de prise entrera et constatera qu'il y a un. thread de mise bloqué, alors les deux correspondront, puis le thread de prise obtient les données du thread de mise, et aucun des deux threads n'est bloqué.

Au contraire, si un thread appelle la méthode take, il bloquera également le thread. Lorsqu'un thread appelant la méthode put arrive, il y correspondra également.

Si un fil de discussion de prise ou de mise arrive et constate qu'un fil de discussion de prise ou de mise du même type est bloqué, alors le fil sera mis en file d'attente vers l'arrière jusqu'à ce qu'un fil d'un type différent arrive et corresponde à l'un des fils .

Je crois qu'à travers la description du processus, j'ai une certaine compréhension de SynchronousQueue, et je sais aussi pourquoi SynchronousQueue n'a pas besoin de stocker d'éléments.

Analyse du code source

En examinant les méthodes take et put de SynchronousQueue, nous avons constaté qu'elles sont toutes deux appelées la méthode de transfert d'un transféreur d'attribut, et que l'attribut du transféreur est la classe interne statique abstraite Transferer de SynchronousQueue . Transferer a deux sous-classes, TransferQueue et TransferStack ;

Dans la méthode constructeur SynchronousQueue, le paramètre transmis fair est utilisé pour déterminer s'il faut créer TransferQueue ou TransferStack. Selon le paramètre fair, TransferQueue doit être en mode fair, alors TransferStack est un non. -mode fonctionnel.

Implémentation de TransferQueue en mode équitable

Tout d'abord, il a une classe interne QNode Grâce à l'analyse ci-dessus, il a été constaté qu'il peut y avoir plusieurs consommateurs ou plusieurs producteurs, et ils formeront une file d'attente, et QNode est utilisé. pour former une liste chaînée.

QNode a principalement quatre attributs :

QNode next : représente le nœud suivant ;

L'élément d'objet ; voici en fait les données mises, le nœud généré par la méthode take est nul

Thread waiter bloqué ; le thread qui génère ce nœud est bloqué et les autres threads se réveilleront après avoir obtenu les données ;

boolean isData : true signifie qu'il est généré par put, false signifie qu'il est généré par take

Puisque take et put dépendent du ; méthode de transfert, Examinons ensuite l'implémentation du transfert. Le code source est trop long, je ne le publierai donc pas. Regardons simplement l'organigramme résumé :

Parce que cette méthode n'utilise pas de verrous. contrôle, il y a encore de nombreux jugements dans l'ensemble du processus. Ceux-ci sont tous mineurs, et les processus principaux et clés sont organisés ici.

Pour expliquer brièvement, l'ensemble du processus repose sur la liste chaînée QNode. Le isData de QNode distingue la méthode take ou put. Les isData des nœuds de la liste chaînée doivent être les mêmes. L'élément de QNode est les données échangées. par les threads take et put, mais les données échangées par la méthode take sont nulles.

On peut voir qu'à chaque fois qu'il peut être mis en correspondance, le nœud avant est récupéré et les données sont renvoyées.

Mode injuste TransferStack

De même, TransferStack a également une structure de liste chaînée appelée SNode. Les principaux attributs de SNode sont les suivants :

SNode next : le nœud suivant

SNode match : Le nœud qui correspond avec succès. it ;

Thread waiter : thread bloqué ;

Object item : la valeur à donner 

int mode : classification des nœuds, utilisé pour distinguer put ou take ;

organise également l'organigramme du code source du transfert ; montré ci-dessous :

Il est également implémenté à l'aide d'une liste chaînée, mais cette première structure est différente. Il y a une correspondance supplémentaire pour représenter le nœud correspondant.

Au cours du processus, vous pouvez voir que le mode a trois valeurs En plus de 0 et 1, il y a aussi un 2 pour représenter le nœud correspondant. Principalement dans la partie rouge de l'image ci-dessus, lorsque constate que le nœud principal n'est pas en cours, le fil de discussion actuel créera un nœud correspondant, puis l'ajoutera à la tête, et enfin le fera correspondre avec les nœuds suivants .

Si une correspondance est trouvée, le nœud correspondant sera supprimé de la liste chaînée.

Grâce à l'analyse du processus, on peut voir que TransferStack est placé en tête du fil qui arrive plus tard et sera mis en correspondance en premier.

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!