Bagikan melalui


Java.Util.Concurrent Ruang nama

Implementasi.

ThreadPoolExecutor Kelas dan ScheduledThreadPoolExecutor menyediakan kumpulan utas yang dapat disesuaikan dan fleksibel.

Kelas

AbstractExecutorService

Menyediakan implementasi ExecutorService default metode eksekusi.

ArrayBlockingQueue

Antrean pemblokiran Antrean Pemblokiran terikat yang didukung oleh array.

BrokenBarrierException

Pengecualian dilemparkan ketika utas mencoba menunggu penghalus yang dalam keadaan rusak, atau yang memasuki status rusak saat utas sedang menunggu.

CancellationException

Pengecualian yang menunjukkan bahwa hasil tugas penghasil nilai, seperti FutureTask, tidak dapat diambil karena tugas dibatalkan.

CompletableFuture

Future yang mungkin diselesaikan secara eksplisit (mengatur nilai dan statusnya), dan dapat digunakan sebagai CompletionStage, mendukung fungsi dan tindakan dependen yang memicu setelah selesai.

CompletionException

Pengecualian dilemparkan ketika kesalahan atau pengecualian lain ditemui selama menyelesaikan hasil atau tugas.

ConcurrentHashMap

Tabel hash yang mendukung konkurensi penuh pengambilan dan konkurensi yang diharapkan tinggi untuk pembaruan.

ConcurrentLinkedDeque

Deque bersamaan yang tidak terbatas berdasarkan simpul yang ditautkan.

ConcurrentLinkedQueue

Antrean Queue aman utas yang tidak terbatas berdasarkan simpul yang ditautkan.

ConcurrentSkipListMap

Implementasi bersamaan ConcurrentNavigableMap yang dapat diskalakan.

CopyOnWriteArrayList

Varian java.util.ArrayList aman utas di mana semua operasi mutasi (add, set, dan sebagainya) diimplementasikan dengan membuat salinan baru dari array yang mendasar.

CopyOnWriteArraySet

Set yang menggunakan internal CopyOnWriteArrayList untuk semua operasinya.

CountDownLatch

Bantuan sinkronisasi yang memungkinkan satu atau beberapa utas menunggu hingga serangkaian operasi dilakukan di utas lain selesai.

CountedCompleter

Dengan ForkJoinTask tindakan penyelesaian yang dilakukan saat dipicu dan tidak ada tindakan yang tersisa yang tertunda.

CyclicBarrier

Bantuan sinkronisasi yang memungkinkan sekumpulan utas untuk semua menunggu satu sama lain mencapai titik pembatas umum.

DelayQueue

Antrean pemblokiran Antrean Pemblokiran Delayed elemen yang tidak terbatas, di mana elemen hanya dapat diambil ketika penundaannya telah kedaluwarsa.

Exchanger

Titik sinkronisasi di mana utas dapat memasangkan dan menukar elemen dalam pasangan.

ExecutionException

Pengecualian dilemparkan saat mencoba mengambil hasil tugas yang dibatalkan dengan melemparkan pengecualian.

ExecutorCompletionService

CompletionService Yang menggunakan yang disediakan Executor untuk menjalankan tugas.

Executors

Metode pabrik dan utilitas untuk Executorkelas , , ExecutorServiceScheduledExecutorService, ThreadFactory, dan Callable yang ditentukan dalam paket ini.

Flow

Antarmuka yang saling terkait dan metode statis untuk membuat komponen yang dikontrol alur di mana menghasilkan item yang Publisher Publishers dikonsumsi oleh satu atau beberapa Subscriber Subscribers, masing-masing dikelola oleh Subscription Subscription.

ForkJoinPool

Untuk ExecutorService menjalankan ForkJoinTasks.

ForkJoinTask

Kelas dasar abstrak untuk tugas yang berjalan dalam ForkJoinPool.

ForkJoinWorkerThread

Utas ForkJoinTaskyang ForkJoinPooldikelola oleh , yang menjalankan s.

FutureTask

Komputasi asinkron yang dapat dibatalkan.

IBlockingDequeExtensions

Implementasi.

ThreadPoolExecutor Kelas dan ScheduledThreadPoolExecutor menyediakan kumpulan utas yang dapat disesuaikan dan fleksibel.

IBlockingQueueExtensions

Implementasi.

ThreadPoolExecutor Kelas dan ScheduledThreadPoolExecutor menyediakan kumpulan utas yang dapat disesuaikan dan fleksibel.

IExecutorServiceExtensions

Implementasi.

ThreadPoolExecutor Kelas dan ScheduledThreadPoolExecutor menyediakan kumpulan utas yang dapat disesuaikan dan fleksibel.

IFutureExtensions

Implementasi.

ThreadPoolExecutor Kelas dan ScheduledThreadPoolExecutor menyediakan kumpulan utas yang dapat disesuaikan dan fleksibel.

LinkedBlockingDeque

Pemblokiran terikat opsionalDeque memblokir deque berdasarkan simpul yang ditautkan.

LinkedBlockingQueue

Antrean pemblokiran Antrean Pemblokiran yang terikat secara opsional berdasarkan simpul yang ditautkan.

LinkedTransferQueue

Tidak terbatas TransferQueue berdasarkan simpul tertaut.

Phaser

Penghambat sinkronisasi yang dapat digunakan kembali, mirip dalam fungsionalitas dengan CyclicBarrier dan CountDownLatch tetapi mendukung penggunaan yang lebih fleksibel.

PriorityBlockingQueue

Antrean pemblokiran Antrean Pemblokiran yang tidak terbatas yang menggunakan aturan pemesanan yang sama dengan kelas PriorityQueue dan menyediakan operasi pengambilan pemblokiran.

RecursiveAction

Hasil rekursif .ForkJoinTask

RecursiveTask

Bearing ForkJoinTaskhasil rekursif .

RejectedExecutionException

Pengecualian yang dilemparkan oleh Executor ketika tugas tidak dapat diterima untuk eksekusi.

ScheduledThreadPoolExecutor

ThreadPoolExecutor Yang juga dapat menjadwalkan perintah untuk dijalankan setelah penundaan tertentu, atau untuk dijalankan secara berkala.

Semaphore

Sebuah semaphore penghitungan.

SubmissionPublisher

Masalah Flow.Publisher asinkron yang dikirimkan (non-null) ke pelanggan saat ini hingga ditutup.

SynchronousQueue

Antrean pemblokiran Antrean pemblokiran di mana setiap operasi penyisipan harus menunggu operasi penghapusan yang sesuai oleh utas lain, dan sebaliknya.

ThreadLocalRandom

Generator angka acak (dengan periode 2<sup>64</sup>) diisolasi ke utas saat ini.

ThreadPoolExecutor

Yang ExecutorService menjalankan setiap tugas yang dikirimkan menggunakan salah satu dari mungkin beberapa utas yang dikumpulkan, biasanya dikonfigurasi menggunakan Executors metode pabrik.

ThreadPoolExecutor.AbortPolicy

Handler untuk tugas yang ditolak yang melempar RejectedExecutionException.

ThreadPoolExecutor.CallerRunsPolicy

Handler untuk tugas yang ditolak yang menjalankan tugas yang ditolak langsung di utas execute panggilan metode, kecuali eksekutor telah dimatikan, dalam hal ini tugas dibuang.

ThreadPoolExecutor.DiscardOldestPolicy

Handler untuk tugas yang ditolak yang membuang permintaan terlama yang tidak tertangani lalu mencoba executekembali , kecuali jika pelaksana dimatikan, dalam hal ini tugas dibuang.

ThreadPoolExecutor.DiscardPolicy

Handler untuk tugas yang ditolak yang secara diam-diam membuang tugas yang ditolak.

TimeoutException

Pengecualian dilemparkan ketika operasi pemblokiran kehabisan waktu.

TimeUnit

Mewakili TimeUnit durasi waktu pada unit granularitas tertentu dan menyediakan metode utilitas untuk dikonversi di seluruh unit, dan untuk melakukan operasi pengaturan waktu dan penundaan dalam unit ini.

Antarmuka

CompletableFuture.IAsynchronousCompletionTask

Antarmuka penanda yang mengidentifikasi tugas asinkron yang dihasilkan oleh async metode.

Flow.IProcessor

Komponen yang bertindak sebagai Pelanggan dan Penerbit.

Flow.IPublisher

Produsen item (dan pesan kontrol terkait) yang diterima oleh Pelanggan.

Flow.ISubscriber

Penerima pesan.

Flow.ISubscription

Kontrol pesan menautkan Publisher dan Subscriber.

ForkJoinPool.IForkJoinWorkerThreadFactory

Pabrik untuk membuat s baru ForkJoinWorkerThread.

ForkJoinPool.IManagedBlocker

Antarmuka untuk memperluas paralelisme terkelola untuk tugas yang berjalan dalam ForkJoinPools.

IBlockingDeque

Deque Yang juga mendukung operasi pemblokiran yang menunggu pencopotan menjadi tidak kosong saat mengambil elemen, dan menunggu ruang tersedia dalam deque saat menyimpan elemen.

IBlockingQueue

Queue Yang juga mendukung operasi yang menunggu antrean menjadi tidak kosong saat mengambil elemen, dan menunggu ruang tersedia dalam antrean saat menyimpan elemen.

ICallable

Tugas yang mengembalikan hasil dan dapat melemparkan pengecualian.

ICompletionService

Layanan yang memisahkan produksi tugas asinkron baru dari konsumsi hasil tugas yang diselesaikan.

ICompletionStage

Tahap komputasi yang mungkin asinkron, yang melakukan tindakan atau menghitung nilai ketika CompletionStage lain selesai.

IConcurrentMap

Jaminan Map keamanan dan atomitas utas yang memberikan.

IDelayed

Antarmuka gaya campuran untuk menandai objek yang harus ditindaklanjuti setelah penundaan tertentu.

IExecutor

Objek yang menjalankan tugas yang dikirimkan Runnable .

IExecutorService

Yang Executor menyediakan metode untuk mengelola penghentian dan metode yang dapat menghasilkan Future untuk melacak kemajuan satu atau beberapa tugas asinkron.

IFuture

mewakili Future hasil komputasi asinkron.

IRejectedExecutionHandler

Handler untuk tugas yang tidak dapat dijalankan oleh ThreadPoolExecutor.

IRunnableFuture

Yang Future adalah Runnable.

IRunnableScheduledFuture

Yang ScheduledFuture adalah Runnable.

IScheduledExecutorService

Yang ExecutorService dapat menjadwalkan perintah untuk dijalankan setelah penundaan tertentu, atau untuk dijalankan secara berkala.

IScheduledFuture

Tindakan pembawaan hasil tertunda yang dapat dibatalkan.

IThreadFactory

Objek yang membuat utas baru sesuai permintaan.

ITransferQueue

Di BlockingQueue mana produsen mungkin menunggu konsumen menerima elemen.