ThreadPoolExecutor in Java is used to execute each submitted task using one of possibly several pooled threads. When an instance of ThreadPoolExecutor is created a thread pool is also created and one of the thread from this pool of threads is used to execute tasks. Java ThreadPoolExecutor ThreadPoolExecutor class is…
ScheduledThreadPoolExecutor in Java adds functionality to schedule commands to run after a given delay, or to execute periodically. Since ScheduledThreadPoolExecutor is an ExecutorService so it uses thread from a thread pool to execute tasks. Table of contents Java ScheduledThreadPoolExecutor Java ScheduledThreadPoolExecutor constructors Creating ScheduledThreadPoolExecutor instance using Executors factory methods Scheduling…
In this Java executor tutorial you’ll learn how to use Executor, ExecutorService, ScheduledExecutorService and their thread pool implementations to effectively manage threads in a large scale application. Table of contents Java Executor API Java Executor interface Java ExecutorService interface Java ScheduledExecutorService interface Java Executor implementation classes Creating executors using Executors…
LinkedTransferQueue in Java is an implementation of the TransferQueue interface and is part of java.util.concurrent package. It was added in Java 7. TransferQueue interface in Java TransferQueue interface which extends BlockingQueue interface adds the capability where producers may wait for consumers to receive elements. In BlockingQueue implementations like ArrayBlockingQueue, PriorityBlockingQueue…
LinkedBlockingDeque in Java is an implementation of BlockingDeque interface and is part of java.util.concurrent package. LinkedBlockingDeque, just like LinkedBlockingQueue, is an optionally-bounded blocking queue which means the capacity for the queue can be specified thus making it bounded or it can be left unspecified in which case capacity of the…
DelayQueue in Java is an implementation of BlockingQueue interface and is part of java.util.concurrent package. DelayQueue in Java is an unbounded queue that’s where it differs from ArrayBlockingQueue which is a bounded queue. Delayed interface Java DelayQueue can store elements only of type Delayed. There is an interface Delayed in…
SynchronousQueue in Java is an implementation of BlockingQueue interface and is part of java.util.concurrent package. SynchronousQueue in Java is different from other BlockingQueue implementations like ArrayBlockingQueue and PriorityBlockingQueue because a synchronous queue does not have any internal capacity, not even a capacity of one. So, each insert operation in SynchronousQueue…
The traditional way of acquiring a mutual exclusion lock in Java is to use synchronized keyword but Java 5 added new lock implementations like ReentrantLock and ReentrantReadWriteLock which provide extended locking operations capabilities. In this post we’ll see the difference between synchronized and ReentrantLock in Java. ReentrantLock Vs synchronized in…
In this post we’ll see the usage of java.util.concurrent.locks.ReadWriteLock interface and its implementing class ReentrantReadWriteLock in Java with examples. Table of contents ReadWriteLock in Java Concurrency Benefits of ReadWriteLock ReentrantReadWriteLock in Java Concurrency Java ReentrantReadWriteLock constructors ReentrantReadWriteLock example in Java ReentrantReadWriteLock Properties ReadWriteLock in Java Concurrency ReadWriteLock as the name…
ReentrantLock in Java is part of java.util.concurrent.locks package with in the Java concurrency API added in Java 5 which also has other classes like ConcurrentHashMap, CountDownLatch. ReentrantLock class in Java implements java.util.concurrent.locks.Lock interface and provide many locking operations. Table of contents ReentrantLock in Java Concurrency Why call it a ReentrantLock…
