public class ThreadPoolExecutorExample {
public static void main(String[] args) {
ExecutorService executorService = new ThreadPoolExecutor(1, 1, 0L, TimeUnit.SECONDS, new LinkedBlockingDeque<>());
for (int i = 0; i < 10; i++) {
executorService.execute(() -> System.out.println(Thread.currentThread()));
}
executorService.shutdown();
}
}
public class SingleThreadScheduledExecutorExample {
public static void main(String[] args) {
ExecutorService executorService = Executors.newSingleThreadScheduledExecutor();
for (int i = 0; i < 10; i++) {
executorService.execute(() -> System.out.println(Thread.currentThread()));
}
executorService.shutdown();
}
}
public class ScheduledThreadPoolExample {
public static void main(String[] args) {
ExecutorService executorService = Executors.newScheduledThreadPool(10);
for (int i = 0; i < 10; i++) {
executorService.execute(() -> System.out.println(Thread.currentThread()));
}
executorService.shutdown();
}
}
public class FixedThreadPoolExample {
public static void main(String[] args) {
ExecutorService executorService = Executors.newFixedThreadPool(10);
for (int i = 0; i < 10; i++) {
executorService.execute(() -> System.out.println(Thread.currentThread()));
}
executorService.shutdown();
}
}
public class CachedThreadPoolExample {
public static void main(String[] args) {
ExecutorService cachedThreadPool = Executors.newCachedThreadPool();
for (int i = 0; i < 10; i++) {
cachedThreadPool.execute(() -> System.out.println(Thread.currentThread()));
}
cachedThreadPool.shutdown();
}
}
public class SingleThreadExecutorExample {
public static void main(String[] args) {
ExecutorService executorService = Executors.newSingleThreadExecutor();
for (int i = 0; i < 10; i++) {
executorService.execute(() -> System.out.println(Thread.currentThread()));
}
executorService.shutdown();
}
}