定时任务单线程和多线程

客官°小女子只卖身不卖艺 2022-01-28 15:19 356阅读 0赞

<table> 
 <tbody> 
 <tr> 
 <td> <code>import java.util.concurrent.Executor;</code> <code>import org.springframework.context.annotation.Bean;</code> <code>import org.springframework.context.annotation.Configuration;</code> <code>import org.springframework.scheduling.annotation.EnableAsync;</code> <code>import org.springframework.scheduling.annotation.EnableScheduling;</code> <code>import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;</code> <code>@Configuration</code> <code>@EnableAsync</code><code>//开启异步事件的支持</code> <code>public</code> <code>class</code> <code>AsyncConfig { </code> &nbsp; <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>/*</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>* 此处成员变量应该使用@Value从配置中读取</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>*/</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>private</code> <code>int</code> <code>corePoolSize = 10;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>private</code> <code>int</code> <code>maxPoolSize = 200;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>private</code> <code>int</code> <code>queueCapacity = 10;</code> &nbsp; <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>@Bean</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>public</code> <code>Executor taskExecutor() { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>ThreadPoolTaskExecutor executor = </code><code>new</code> <code>ThreadPoolTaskExecutor();</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>executor.setCorePoolSize(corePoolSize);</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>executor.setMaxPoolSize(maxPoolSize);</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>executor.setQueueCapacity(queueCapacity);</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>executor.initialize();</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code> <code>executor;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> &nbsp; <code>}</code> </td> 
 </tr> 
 </tbody> 
</table>

2、定时任务类

[\+  ][ ][?][ ]

<table> 
 <tbody> 
 <tr> 
 <td> 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 </td> 
 <td> <code>import org.slf4j.Logger;</code> <code>import org.slf4j.LoggerFactory;</code> <code>import org.springframework.scheduling.annotation.Async;</code> <code>import org.springframework.scheduling.annotation.EnableScheduling;</code> <code>import org.springframework.scheduling.annotation.Scheduled;</code> <code>import org.springframework.stereotype.Component;</code> <code>@Component</code> <code>@EnableScheduling</code> <code>public</code> <code>class</code> <code>ScheduledService { </code> &nbsp; <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>private</code> <code>Logger logger = LoggerFactory.getLogger(ScheduledService.</code><code>class</code><code>);</code> &nbsp; <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>@Scheduled(cron = </code><code>"0/5 * * * * *"</code><code>)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>@Async</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>public</code> <code>void</code> <code>scheduled() { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>logger.info(</code><code>"=====&gt;&gt;&gt;&gt;&gt;使用cron&nbsp; {}"</code><code>, System.currentTimeMillis());</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> &nbsp; <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>@Scheduled(fixedRate = 5000)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>@Async</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>public</code> <code>void</code> <code>scheduled1() { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>logger.info(</code><code>"=====&gt;&gt;&gt;&gt;&gt;使用fixedRate{}"</code><code>, System.currentTimeMillis());</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> &nbsp; <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>@Scheduled(fixedDelay = 5000)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>@Async</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>public</code> <code>void</code> <code>scheduled2() { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>logger.info(</code><code>"=====&gt;&gt;&gt;&gt;&gt;fixedDelay{}"</code><code>, System.currentTimeMillis());</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>}</code> </td> 
 </tr> 
 </tbody> 
</table>

[ ]: http://www.cnblogs.com/lichangyunnianxue/p/9771517.html#