multithreading - Java ThreadPoolExecutor and BlockingQueue to be used -


in oracle site (http://docs.oracle.com/javase/7/docs/api/?java/util/concurrent/threadpoolexecutor.html) under queuing section, mentioned "if corepoolsize or more threads running, executor prefers queuing request rather adding new thread."

lot of our code have corepoolsize 1 , maximumpoolsize 10 or 20. (1) bad practice? or rather not optimal way use threadpool's? (2) recommend have corepoolsize , maximumpoolsize value same when creating threadpoolexecutor?

another question respect usage of blockingqueue while creating threadpoolexecutor - between linkedblockingqueue or concurrentlinkedqueue? looking more locking , performance point-of-view? though running test proves, inserting in concurrentlinkedqueue quite fast compared other. thoughts?

edited:

the first part has been answered in various questions. 1 liked how threadpoolexecutor increase threads max before queueing?

please find bellow points .

  1. if new task submitted list of tasks executed, , less corepoolsize threads running, new thread created handle request. incoming tasks queued in case corepoolsize or more threads running.

  2. if request can’t queued or there less corepoolsize threads running, new thread created unless exceed maximumpoolsize.

  3. if pool has more corepoolsize threads, excess threads terminated if have been idle more keepalivetime.

  4. if new task submitted list of tasks executed , there more corepoolsize less maximumpoolsize threads running, new thread created if queue full. means when using unbounded queue, no more threads corepoolsize running , keepalivetime has no influence.

  5. if corepoolsize , maximumpoolsize same, fixed-size thread pool used

    your threadpool size

    core pool size 1.

    max pool size 10 or 20.

question 1 : bad practice? or rather not optimal way use threadpool's?

it based on pool used.

if using bounded queue , new thread created upto max size once reaches max limit of bounded queue. otherwise run in core pool size . if using unbounded queue core pool size only.

question 2 : recommend have corepoolsize , maximumpoolsize value same when creating threadpoolexecutor?

yes. can same no of threads instead of kind blocking queue . non blocking queue can max no of threads.

question 3 concurrentlinkedqueue vs linkedblockingqueue

you should not allow use concurrentlinkedqueue since threadpool supports blockingqueue. may try concurrentlinkedblockingqueue. because concurrentlinkedblockingqueue unbounded. linkedblockingqueue bounded.


Comments

Post a Comment

Popular posts from this blog

android - Get AccessToken using signpost OAuth without opening a browser (Two legged Oauth) -

i using signpost oauth access data magento server. have read various tutorials on same , reach point open browser user can enter credentials. however, per requirement have automate part. hence, user should not browser page. have set-up done on server side ( magento ), hit url , returned call page. same through program in android. i have tried below, consumer = new commonshttpoauthconsumer(key, secret); provider = new commonshttpoauthprovider(oauth_init_url,access_token_url, authorize_url); try { provider.retrieverequesttoken(consumer, oauth.out_of_band); log.d("tokens" , consumer.gettoken() + " -- " + consumer.gettokensecret()); } and request tokens. dont know how bypass next step. tried directly accessing accesstoken (stupid of me) provider.retrieveaccesstoken(consumer, "mycallback://callback"); no luck, ends in oauth.signpost.exception.oauthnotauthorizedexception: authorization failed (server replied 401). ...
Read more

org.mockito.exceptions.misusing.InvalidUseOfMatchersException: mockito -

getting error org.mockito.exceptions.misusing.invaliduseofmatchersexception: invalid use of argument matchers! 1 matchers expected, 2 recorded. exception may occur if matchers combined raw values: //incorrect: somemethod(anyobject(), "raw string"); when using matchers, arguments have provided matchers. example: //correct: somemethod(anyobject(), eq("string matcher")); at when( getprogramservice .callservice(any(getprogramtype.class))) .thenreturn(jaxbresponse); please explain error , possible resolution the code posted looks fine; don't see problem it. code before or above causing exception. key here: invalid use of argument matchers! 1 matchers expected, 2 recorded. any , used above, doesn't return "special kind of null" or "special kind of getprogramtype"; don't exist. instead, returns null , side effect puts matcher on stack. whe...
Read more

google shop client API returns 400 bad request error while adding an item -

i'm working on solution add items in google shopping market java application. following tutorial real mess because of missing classes of laste release, after setting 1.5-beta maven managed make base example typecheck correctly classes. still can make simple task of adding 1 item. instead of posting whole code i'm posting part creates product feed. private product createproduct(string id) { product product = new product(); product.title = "red wool sweater"; product.content = new content( "text", "comfortable , soft, sweater keep warm on " + "cold winter nights. red , blue stripes."); product.appcontrol = new appcontrol(); product.appcontrol.addrequireddestination("productads"); product.externalid = id; product.lang = "it"; product.country = "it"; product.condition = "nuovo"; product.price = new price("eu...
Read more