Java Executors newScheduledThreadPool() Method

by Online Tutorials Library July 22, 2022

Java Executors newScheduledThreadPool() Method

The newScheduledThreadPool() method of Executors class creates a thread pool that can schedule commands to run after a given delay or to execute periodically.

Syntax

  Public static ScheduledExecutorService newScheduledThreadPool(int corePoolSize)  public static ScheduledExecutorService newScheduledThreadPool(int corePoolSize, ThreadFactory threadFactory)  

Parameter

corePoolSize – the number of threads to keep in the pool, even if they are idle

threadFactory – the factory to use when the executor creates a new thread

Returns

a newly created scheduled thread pool

Throw

NullPointerException

IllegalArgumentException

Example 1

  import java.util.concurrent.ExecutorService;  import java.util.concurrent.Executors;  import java.util.concurrent.ScheduledExecutorService;  import java.util.concurrent.ThreadFactory;  import java.util.concurrent.ThreadPoolExecutor;  import java.util.concurrent.TimeUnit;    public class ExecutorsnewSheduledThreadPoollExample1  {       public static void main(final String[] arguments) throws InterruptedException {               ScheduledExecutorService scheduler = Executors.newScheduledThreadPool( 3 );         ThreadFactory ThreadFactory = Executors.defaultThreadFactory();          System.out.println(scheduler.getClass());        ExecutorService excr = Executors.newCachedThreadPool(ThreadFactory);        ThreadPoolExecutor mypool = (ThreadPoolExecutor) excr;        System.out.println(“size of mypool: ” + mypool.getPoolSize());              excr.submit(new Threadimpl());                excr.shutdown();     }         static class Threadimpl implements Runnable {          public void run() {                      try {              Long num = (long) (Math.random() / 30);              System.out.println(“Thread Name: ” +Thread.currentThread().getName());                 TimeUnit.SECONDS.sleep(num);              System.out.println(“after sleep Thread Name: ” +Thread.currentThread().getName());           } catch (InterruptedException e) {              e.printStackTrace();           }        }     }  }  

Test it Now

Output:

class java.util.concurrent.ScheduledThreadPoolExecutor  size of mypool: 0  Thread Name: pool-2-thread-1  after sleep Thread Name: pool-2-thread-1

Example 2

  import java.util.concurrent.ExecutorService;  import java.util.concurrent.Executors;  import java.util.concurrent.ScheduledExecutorService;  import java.util.concurrent.ThreadFactory;  import java.util.concurrent.ThreadPoolExecutor;  import java.util.concurrent.TimeUnit;    public class ExecutorsnewSheduledThreadPoollExample2  {       public static void main(final String[] arguments) throws InterruptedException {               ScheduledExecutorService scheduler = Executors.newScheduledThreadPool( 3 );         ThreadFactory ThreadFactory = Executors.defaultThreadFactory();          System.out.println(scheduler.getClass());        ExecutorService excr = Executors.newCachedThreadPool(ThreadFactory);        ThreadPoolExecutor mypool = (ThreadPoolExecutor) excr;        System.out.println(“size of mypool: ” + mypool.getPoolSize());                         System.out.println(scheduler.isShutdown());                  System.out.println(scheduler.getClass());        excr.shutdown();     }          }  

Test it Now

Output:

class java.util.concurrent.ScheduledThreadPoolExecutor  size of mypool: 0  false  class java.util.concurrent.ScheduledThreadPoolExecutor

Next TopicJava Executors

callable()defaultThreadFactory()Executors java newCachedThreadPool()newScheduledThreadPool()newSingleThreadExecutor()privilegedThreadFactory()

Java Executors newScheduledThreadPool() Method

Java Executors newScheduledThreadPool() Method

Syntax

Parameter

Returns

Throw

Example 1

Example 2

Java ConcurrentHashMap putIfAbsent() Method

Java Abstract Keyword

You may also like