Toggle navigation
Home
java.util.concurrent.ExecutorService to java.util.concurrent.ThreadPoolExecutor
No. of Instances - 28
No. of Commits - 14
No. of Projects - {'AxonFramework', 'hbase', 'geoserver', 'jetty.project', 'ignite', 'hadoop', 'Singularity', 'rapidoid', 'nd4j', 'killbill', 'infinispan', 'optaplanner'}
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