Toggle navigation
Home
java.util.concurrent.ExecutorService to java.util.concurrent.ThreadPoolExecutor
No. of Instances - 1
No. of Commits - 1
No. of Projects - {'AxonFramework'}
Hierarchy/Composition: T_SUPER_R
Primitive Info: -
NameSpace: Jdk -> Jdk
Mapping:
Cascading Type Change (Different)
LinkedBlockingQueue<>
to
SynchronousQueue<>
Update argument list (Class Instance Creation)
ThreadPoolExecutor
to
ThreadPoolExecutor
Rename Variable
executorService
to
threadPoolExecutor
Add or Remove Method invocation
Long.MAX_VALUE
to
getStopTimeout()
Update Class Instacne Creation
new LinkedBlockingQueue<Runnable>(DFLT_PUBLIC_THREADPOOL_QUEUE_CAP)
to
new LinkedBlockingQueue<Runnable>()
new LinkedBlockingQueue<Runnable>(DFLT_SYSTEM_THREADPOOL_QUEUE_CAP)
to
new LinkedBlockingQueue<Runnable>()
new IgniteThreadPoolExecutor("utility",cfg.getGridName(),myCfg.getUtilityCacheThreadPoolSize(),myCfg.getUtilityCacheThreadPoolSize(),myCfg.getUtilityCacheKeepAliveTime(),new LinkedBlockingQueue<Runnable>(DFLT_SYSTEM_THREADPOOL_QUEUE_CAP))
to
new IgniteThreadPoolExecutor("utility",cfg.getGridName(),myCfg.getUtilityCacheThreadPoolSize(),myCfg.getUtilityCacheThreadPoolSize(),myCfg.getUtilityCacheKeepAliveTime(),new LinkedBlockingQueue<Runnable>())
new IgniteThreadPoolExecutor("marshaller-cache",cfg.getGridName(),myCfg.getMarshallerCacheThreadPoolSize(),myCfg.getMarshallerCacheThreadPoolSize(),myCfg.getMarshallerCacheKeepAliveTime(),new LinkedBlockingQueue<Runnable>(DFLT_SYSTEM_THREADPOOL_QUEUE_CAP))
to
new IgniteThreadPoolExecutor("marshaller-cache",cfg.getGridName(),myCfg.getMarshallerCacheThreadPoolSize(),myCfg.getMarshallerCacheThreadPoolSize(),myCfg.getMarshallerCacheKeepAliveTime(),new LinkedBlockingQueue<Runnable>())
new IgniteThreadPoolExecutor("igfs",cfg.getGridName(),cfg.getIgfsThreadPoolSize(),cfg.getIgfsThreadPoolSize(),DFLT_THREAD_KEEP_ALIVE_TIME,new LinkedBlockingQueue<Runnable>())
to
new IgniteThreadPoolExecutor(cfg.getIgfsThreadPoolSize(),cfg.getIgfsThreadPoolSize(),DFLT_THREAD_KEEP_ALIVE_TIME,new LinkedBlockingQueue<Runnable>(),new IgfsThreadFactory(cfg.getGridName(),"igfs"),null)
Other
0
to
DFLT_THREAD_KEEP_ALIVE_TIME
0
to
DFLT_THREAD_KEEP_ALIVE_TIME
0
to
DFLT_THREAD_KEEP_ALIVE_TIME