How to increase no of threads to run concurrently in AEM 6.1 | Community
Skip to main content
Ratna_Kumar
Ratna_Kumar
Level 10
July 20, 2016
Solved

How to increase no of threads to run concurrently in AEM 6.1

  • July 20, 2016
  • 5 replies
  • 4242 views

Hi,

How to increase the number of threads to run in usage in AEM6.1 through Sling thread pool configuration.

Actually I need to run more than 5 threads concurrently, so I have increased the default MIN_POOL size from 5 to 20. But it is not working.

I have tried also changing in Apache sling job queue configuration and also tried to increase the POOL size by writing a custom service, but it still taking only 5 threads.

Can anyone please help me on this.

Thanks,
Ratna Kumar.

This post is no longer active and is closed to new replies. Need help? Start a new post to ask your question.
Best answer by kautuk_sahni

Hi Ratna

One of my recent read includes the "How to use sling thread pool in AEM".

Link:- http://www.wemblog.com/2014/04/how-to-use-sling-thread-pool-in-cqaem.html (Old article but may be useful).

//

    Use Case: You are designing an application where you might need to delegate Job to a separate thread and you want to control this using thread pool so that your application it self does not run out of threads.

    Prerequisite: Knowledge of Java Threads and basic Knowledge of thread pool. Note that there are Java Level thread pool as well that you can use. Check     http://docs.oracle.com/javase/7/docs/api/java/util/concurrent/package-summary.html for that.

    Reference: https://sling.apache.org/documentation/bundles/apache-sling-commons-thread-pool.html

I hope this might help you.

Thanks and Regards

Kautuk Sahni

5 replies

kautuk_sahni
Community Manager
kautuk_sahniCommunity ManagerAccepted solution
Community Manager
July 20, 2016

Hi Ratna

One of my recent read includes the "How to use sling thread pool in AEM".

Link:- http://www.wemblog.com/2014/04/how-to-use-sling-thread-pool-in-cqaem.html (Old article but may be useful).

//

    Use Case: You are designing an application where you might need to delegate Job to a separate thread and you want to control this using thread pool so that your application it self does not run out of threads.

    Prerequisite: Knowledge of Java Threads and basic Knowledge of thread pool. Note that there are Java Level thread pool as well that you can use. Check     http://docs.oracle.com/javase/7/docs/api/java/util/concurrent/package-summary.html for that.

    Reference: https://sling.apache.org/documentation/bundles/apache-sling-commons-thread-pool.html

I hope this might help you.

Thanks and Regards

Kautuk Sahni

Kautuk Sahni
Ratna_Kumar
Ratna_KumarAuthor
Level 10
July 20, 2016

Hi Kautuk,

I have tried already in the above mentioned perspective by you.

Still have the issue. So if you can give any other solution if possible, that would be great.

Anyway thanks for your fast reply. 

Thanks,
Ratna kumar.

Ratna_Kumar
Ratna_KumarAuthor
Level 10
July 20, 2016

Hi Kautuk,

The issue has been resolved.

We have wrongly configured the POOL_SIZE in service.

Thanks,
Ratna Kumar,

kautuk_sahni
Community Manager
kautuk_sahniCommunity Manager
Community Manager
July 20, 2016

Please share what you were doing wrong and how it was rectified for communities benefit.

Thanks Ratna in advance.

 

Thanks and Regards

Kautuk Sahni

Kautuk Sahni
Ratna_Kumar
Ratna_KumarAuthor
Level 10
July 20, 2016

Hi Kautuk,

There is only one minor mistake I have done while configuring the POOL_SIZE.  Like for example

                                                                        
@Activate
 protected final void activate(final Map<Object, Object> config) {
 this.minThreadPoolSize = OsgiUtil.toInteger(config.get(MINIMUM_THREAD_POOL_SIZE), 5);
 this.maxThreadPoolSize = OsgiUtil.toInteger(config.get(MAXUIMUM_THREAD_POOL_SIZE), 10);
 ModifiableThreadPoolConfig threadPoolConfig = new ModifiableThreadPoolConfig();
 if(threadPoolConfig.getMinPoolSize()<this.minThreadPoolSize) {
 threadPoolConfig.setMinPoolSize(this.minThreadPoolSize);
 }
 if(threadPoolConfig.getMaxPoolSize()<this.maxThreadPoolSize) {
 threadPoolConfig.setMaxPoolSize(this.maxThreadPoolSize);
 }
 //You can make this configurable as well
 threadPoolConfig.setPriority(ThreadPriority.NORM);
 this.threadPool = threadPoolManager.create(threadPoolConfig);
 if(threadPool == null) {
 throw new IllegalStateException("Could not get a ThreadPool");
 }
 }

Here I am calling this.threadPool = threadPoolManager.create(threadPoolConfig) before configuring threadPoolConfig.setPriority(ThreadPriority.NORM);

this.threadPool = threadPoolManager.create(threadPoolConfig);
threadPoolConfig.setPriority(ThreadPriority.NORM);

But it must be 

threadPoolConfig.setPriority(ThreadPriority.NORM);
this.threadPool = threadPoolManager.create(threadPoolConfig);

So that is why it is running 5 threads by default.

Thanks,
Ratna Kumar.

Terms & ConditionsAccessibility statement

Loading footer...