Java.Util.Concurrent Espace de noms

Fournit des implémentations par défaut des méthodes d’exécution ExecutorService .

File d’attente bloquante bloquante BlockingQueue limitée soutenue par un tableau.

Exception levée lorsqu’un thread tente d’attendre une barrière dans un état rompu ou qui entre dans l’état rompu pendant l’attente du thread.

Exception indiquant que le résultat d’une tâche de production de valeur, telle qu’une FutureTasktâche , ne peut pas être récupérée, car la tâche a été annulée.

Un Future qui peut être explicitement terminé (définition de sa valeur et de son état) et peut être utilisé en tant que CompletionStagefonctions dépendantes et actions qui se déclenchent à sa fin.

Exception levée lorsqu’une erreur ou une autre exception est rencontrée au cours de l’exécution d’un résultat ou d’une tâche.

Table de hachage prenant en charge la concurrence complète des récupérations et une concurrence attendue élevée pour les mises à jour.

Une file d’attente simultanée non liée basée sur des nœuds liés.

File d’attente thread-safe non liée basée sur des nœuds liés.

Implémentation simultanée ConcurrentNavigableMap évolutive.

Variante thread-safe dont java.util.ArrayList toutes les opérations mutatives (add, setet ainsi de suite) sont implémentées en effectuant une nouvelle copie du tableau sous-jacent.

Qui Set utilise un élément interne CopyOnWriteArrayList pour toutes ses opérations.

Aide de synchronisation qui permet à un ou plusieurs threads d’attendre qu’un ensemble d’opérations en cours d’exécution dans d’autres threads se termine.

Avec ForkJoinTask une action de saisie semi-automatique effectuée lorsqu’elle est déclenchée et qu’il n’y a pas d’actions en attente restantes.

Aide de synchronisation qui permet à un ensemble de threads d’attendre l’un de l’autre pour atteindre un point de barrière commun.

File d’attente bloquante de Blocage Dequeue non délimitée d’éléments Delayed , dans laquelle un élément ne peut être pris que lorsque son délai a expiré.

Point de synchronisation auquel les threads peuvent associer et échanger des éléments au sein de paires.

Exception levée lors d’une tentative de récupération du résultat d’une tâche abandonnée en lève une exception.

Qui CompletionService utilise un élément fourni Executor pour exécuter des tâches.

Méthodes d’usine et d’utilitaire pour Executor, ExecutorService, ScheduledExecutorService, ThreadFactoryet Callable classes définies dans ce package.

Interfaces liées et méthodes statiques permettant d’établir des composants contrôlés par flux dans lesquels Publisher Publishers produisent des éléments consommés par un ou plusieurs Subscriber Subscribers, chacun géré par un Subscription Subscription.

Pour ExecutorService l’exécution ForkJoinTaskde s.

Classe de base abstraite pour les tâches qui s’exécutent dans un ForkJoinPool.

Thread géré par un ForkJoinPool, qui exécute s ForkJoinTask.

Calcul asynchrone annulable.

Implémentations.

Classes ThreadPoolExecutor et ScheduledThreadPoolExecutor fournir des pools de threads flexibles et paramétrables.

Implémentations.

Classes ThreadPoolExecutor et ScheduledThreadPoolExecutor fournir des pools de threads flexibles et paramétrables.

Implémentations.

Classes ThreadPoolExecutor et ScheduledThreadPoolExecutor fournir des pools de threads flexibles et paramétrables.

Implémentations.

Classes ThreadPoolExecutor et ScheduledThreadPoolExecutor fournir des pools de threads flexibles et paramétrables.

Une file d’attente bloquante BlockingDeque éventuellement limitée en fonction des nœuds liés.

File d’attente bloquante BlockingQueue limitée facultativement basée sur des nœuds liés.

Un nœud TransferQueue lié basé sur des nœuds liés.

Barrière de synchronisation réutilisable, similaire à la fonctionnalité et CountDownLatch prenant CyclicBarrier en charge une utilisation plus flexible.

File d’attente bloquante BlockingQueue sans limite qui utilise les mêmes règles de classement que la classe PriorityQueue et fournit des opérations de récupération bloquantes.

Un résultat ForkJoinTaskrécursif .

Un résultat ForkJoinTaskrécursif .

Exception levée par une Executor tâche lorsqu’une tâche ne peut pas être acceptée pour l’exécution.

Qui ThreadPoolExecutor peut également planifier l’exécution de commandes après un délai donné ou pour s’exécuter régulièrement.

Sémaphore de comptage.

Qui Flow.Publisher émet de façon asynchrone des éléments soumis (non null) aux abonnés actuels jusqu’à ce qu’il soit fermé.

File d’attente bloquante BlockingQueue dans laquelle chaque opération d’insertion doit attendre une opération de suppression correspondante par un autre thread, et inversement.

Générateur de nombres aléatoires (avec la période 2⁶⁴) isolé au thread actuel.

Qui ExecutorService exécute chaque tâche envoyée à l’aide de l’un des threads mis en pool, normalement configuré à l’aide Executors de méthodes de fabrique.

Gestionnaire des tâches rejetées qui lève un RejectedExecutionException.

Gestionnaire des tâches rejetées qui exécutent la tâche rejetée directement dans le thread appelant de la execute méthode, sauf si l’exécuteur a été arrêté, auquel cas la tâche est ignorée.

Gestionnaire des tâches rejetées qui ignore la demande non gérée la plus ancienne, puis réessaye execute, sauf si l’exécuteur est arrêté, auquel cas la tâche est ignorée.

Gestionnaire pour les tâches rejetées qui ignorent silencieusement la tâche rejetée.

Exception levée lorsqu’une opération bloquante expire.

Représente TimeUnit des durées de temps à une unité de granularité donnée et fournit des méthodes utilitaires pour convertir les unités, et pour effectuer des opérations de minutage et de retard dans ces unités.

Interface de marqueur identifiant les tâches asynchrones produites par async des méthodes.

Composant qui agit à la fois en tant qu’Abonné et Serveur de publication.

Producteur d’éléments (et messages de contrôle connexes) reçus par les Abonnés.

Récepteur de messages.

Contrôle de message liant a Publisher et Subscriber.

Fabrique de création de s ForkJoinWorkerThread.

Interface permettant d’étendre le parallélisme managé pour les tâches exécutées dans ForkJoinPools.

Qui Deque prend également en charge les opérations bloquantes qui attendent que la file d’attente devienne non vide lors de la récupération d’un élément et attend que l’espace devienne disponible dans la file d’attente lors du stockage d’un élément.

Qui Queue prend également en charge les opérations qui attendent que la file d’attente devienne non vide lors de la récupération d’un élément et attend que l’espace soit disponible dans la file d’attente lors du stockage d’un élément.

Tâche qui retourne un résultat et peut lever une exception.

Service qui dissocie la production de nouvelles tâches asynchrones de la consommation des résultats des tâches terminées.

Étape d’un calcul éventuellement asynchrone, qui effectue une action ou calcule une valeur quand un autre CompletionStage se termine.

Garantie Map de sécurité et d’atomicité des threads.

Interface de style mix-in pour marquer les objets qui doivent être pris en compte après un délai donné.

Objet qui exécute des tâches envoyées Runnable .

Qui Executor fournit des méthodes pour gérer l’arrêt et les méthodes qui peuvent produire un Future pour le suivi de la progression d’une ou plusieurs tâches asynchrones.

Représente Future le résultat d’un calcul asynchrone.

Gestionnaire pour les tâches qui ne peuvent pas être exécutées par un ThreadPoolExecutor.

Un Future qui est Runnable.

Un ScheduledFuture qui est Runnable.

Qui ExecutorService peut planifier l’exécution de commandes après un délai donné ou pour s’exécuter régulièrement.

Action de résultat différée qui peut être annulée.

Objet qui crée de nouveaux threads à la demande.

Dans BlockingQueue laquelle les producteurs peuvent attendre que les consommateurs reçoivent des éléments.