CODEWITHSUNDEEP
javaspring
Abhishek Agarwal
Abhishek Agarwal

Reputation: 922

How to run more than two threads simultaneosly

private final ExecutorService pool = Executors.newFixedThreadPool(5);

for (ProductInfo prod : product) {
                pool.execute(new Runnable() {
                    @Override
                    public void run() {
                        try {
                            prod.checkout(processList);
                        } catch (InterruptedException e) {
                            log.error("PRODUCT INFO EXCEPTION", e);
                        }
                    }
                });
            }

All calls to prod.checkout method call different apis having no correlation between them.

ProductInfo.java

@Async
    public void checkout(List<ProcessLog> list) throws InterruptedException {
        process = processUtil.start(getHome(), job);
        list.add(process);
        preprocess();
        execute();
        postprocess();
        list.remove(process);
        processUtil.end(process);
    }

At any time i see only two threads running, what can i do to make 5 threads running at any time?

Upvotes: 1

Views: 98

Answers (2)

Ralph
Ralph

Reputation: 120871

Use TWO beans.

@Service   
public class CheckoutService {

    @Async
    public void checkout(List<ProcessLog> list) throws InterruptedException {
        process = processUtil.start(getHome(), job);
        list.add(process);
        preprocess();
        execute();
        postprocess();
        list.remove(process);
        processUtil.end(process);
    }
}

The second bean invoke the first one, so Spring can handle @Aync (see this answer for more details about the reason for splitting: https://stackoverflow.com/a/22561903/280244)

@Service   
public class CheckoutAsyncInvoker {

    @Autowired
    CheckoutService  checkoutService 

    public void runner()
        for (ProductInfo prod : product) {
            processList=...
            this.checkoutService.checkout(processList);
        }
    }
}

Configuration:

 @Configuration
 @EnableAsync
 public class AppConfig implements AsyncConfigurer {

     @Override
     public Executor getAsyncExecutor() {
         ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
         executor.setCorePoolSize(5);
         executor.setMaxPoolSize(5);
         executor.setQueueCapacity(11);
         executor.setThreadNamePrefix("MyExecutor-");
         executor.initialize();
         return executor;
     }
 }

Upvotes: 1

prem kumar
prem kumar

Reputation: 5877

May be it is because there is @Async annotation on checkout() method. As soon as checkout() method is called execution in run() method mentioned here is completed and code within checkout() is running in a altogether different thread different from this thread pool.

If you remove this annotation and ensure the method executes for quite some time then you can see that all 5 threads getting used up.

Upvotes: 0

Related Questions