Java Executors newWorkStealingPool() Method

by Online Tutorials Library July 22, 2022

Java Executor newWorkStealingPool() Method

The newWorkStealingPool() method of Executors class creates a work-stealing thread pool using the number of available processors as its target parallelism level.

Syntax

  public static ExecutorService newWorkStealingPool()  public static ExecutorService newWorkStealingPool(int parallelism)  

Parameter

parallelism – the targeted parallelism level

Returns

the newly created thread pool

Throw

IllegalArgumentException

Example 1

  import java.util.concurrent.ExecutorService;  import java.util.concurrent.Executors;  import java.util.concurrent.ThreadPoolExecutor;  import java.util.concurrent.TimeUnit;    public class ExecutorsnewWorkStealingPoolExample1  {       public static void main(final String[] arguments) throws InterruptedException {        ExecutorService excr = Executors.newWorkStealingPool();        ThreadPoolExecutor mypool = (ThreadPoolExecutor)  Executors.newCachedThreadPool();;        System.out.println(“size of mypool: ” + mypool.getPoolSize());        excr.submit(new Threadimpl());        excr.submit(new Threadimpl());        System.out.println(“Total number threads scheduled): “+ mypool.getTaskCount());        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:

size of mypool: 0  Thread Name: ForkJoinPool-1-worker-5  after sleep Thread Name: ForkJoinPool-1-worker-5  Thread Name: ForkJoinPool-1-worker-3  after sleep Thread Name: ForkJoinPool-1-worker-3  Total number threads scheduled): 0

Example 1

  import java.util.concurrent.ExecutorService;  import java.util.concurrent.Executors;  import java.util.concurrent.ThreadPoolExecutor;  import java.util.concurrent.TimeUnit;    public class ExecutorsnewWorkStealingPoolExample2  {       public static void main(final String[] arguments) throws InterruptedException {        ExecutorService excr = Executors.newWorkStealingPool(4);        ThreadPoolExecutor mypool = (ThreadPoolExecutor)  Executors.newCachedThreadPool();;        System.out.println(“size of mypool: ” + mypool.getPoolSize());        excr.submit(new Threadimpl());        excr.submit(new Threadimpl());        System.out.println(“Total number threads scheduled): “+ mypool.getTaskCount());        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:

size of mypool: 0  Thread Name: ForkJoinPool-1-worker-5  after sleep Thread Name: ForkJoinPool-1-worker-5  Thread Name: ForkJoinPool-1-worker-3  after sleep Thread Name: ForkJoinPool-1-worker-3  Total number threads scheduled): 0

Next TopicJava Executors

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

Java Executors newWorkStealingPool() Method

Java Executor newWorkStealingPool() Method

Syntax

Parameter

Returns

Throw

Example 1

Example 1

Java ConcurrentHashMap putIfAbsent() Method

Java Abstract Keyword

You may also like