lsm/hutool
1
0
Fork 0
mirror of https://gitee.com/dromara/hutool.git synced 2025-04-05 17:37:59 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

add method

Browse Source
This commit is contained in:
Looly 2021-06-07 00:39:21 +08:00
parent 7693bc131e
commit 028c3ed60d
1 changed files with 31 additions and 19 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

50
hutool-core/src/main/java/cn/hutool/core/thread/ThreadUtil.java
View File

@ -12,6 +12,7 @@ import java.util.concurrent.ScheduledThreadPoolExecutor;
import java.util.concurrent.ThreadFactory; import java.util.concurrent.ThreadFactory;
import java.util.concurrent.ThreadPoolExecutor; import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit; import java.util.concurrent.TimeUnit;
import java.util.function.Supplier;
/** /**
* 线程池工具 * 线程池工具
@ -366,6 +367,19 @@ public class ThreadUtil {
} }
} }
/**
* 创建本地线程对象
*
* @param <T> 持有对象类型
* @param supplier 初始化线程对象函数
* @return 本地线程
* @see ThreadLocal#withInitial(Supplier)
* @since 5.6.7
*/
public static <T> ThreadLocal<T> createThreadLocal(Supplier<? extends T> supplier) {
return ThreadLocal.withInitial(supplier);
}
/** /**
* 创建ThreadFactoryBuilder * 创建ThreadFactoryBuilder
* *
@ -562,20 +576,19 @@ public class ThreadUtil {
* <li>fixedDelay模式：下一次任务不等待上一次任务，到周期自动执行。</li> * <li>fixedDelay模式：下一次任务不等待上一次任务，到周期自动执行。</li>
* </ul> * </ul>
* *
* * @param executor 定时任务线程池，{@code null}新建一个默认线程池
* @param executor 定时任务线程池，{@code null}新建一个默认线程池 * @param command 需要定时执行的逻辑
* @param command 需要定时执行的逻辑 * @param initialDelay 初始延迟，单位毫秒
* @param initialDelay 初始延迟，单位毫秒 * @param period 执行周期，单位毫秒
* @param period 执行周期，单位毫秒
* @param fixedRateOrFixedDelay {@code true}表示fixedRate模式，{@code false}表示fixedDelay模式 * @param fixedRateOrFixedDelay {@code true}表示fixedRate模式，{@code false}表示fixedDelay模式
* @return {@link ScheduledThreadPoolExecutor} * @return {@link ScheduledThreadPoolExecutor}
* @since 5.5.8 * @since 5.5.8
*/ */
public static ScheduledThreadPoolExecutor schedule(ScheduledThreadPoolExecutor executor, public static ScheduledThreadPoolExecutor schedule(ScheduledThreadPoolExecutor executor,
Runnable command, Runnable command,
long initialDelay, long initialDelay,
long period, long period,
boolean fixedRateOrFixedDelay){ boolean fixedRateOrFixedDelay) {
return schedule(executor, command, initialDelay, period, TimeUnit.MILLISECONDS, fixedRateOrFixedDelay); return schedule(executor, command, initialDelay, period, TimeUnit.MILLISECONDS, fixedRateOrFixedDelay);
} }
@ -587,12 +600,11 @@ public class ThreadUtil {
* <li>fixedDelay模式：下一次任务不等待上一次任务，到周期自动执行。</li> * <li>fixedDelay模式：下一次任务不等待上一次任务，到周期自动执行。</li>
* </ul> * </ul>
* *
* * @param executor 定时任务线程池，{@code null}新建一个默认线程池
* @param executor 定时任务线程池，{@code null}新建一个默认线程池 * @param command 需要定时执行的逻辑
* @param command 需要定时执行的逻辑 * @param initialDelay 初始延迟
* @param initialDelay 初始延迟 * @param period 执行周期
* @param period 执行周期 * @param timeUnit 时间单位
* @param timeUnit 时间单位
* @param fixedRateOrFixedDelay {@code true}表示fixedRate模式，{@code false}表示fixedDelay模式 * @param fixedRateOrFixedDelay {@code true}表示fixedRate模式，{@code false}表示fixedDelay模式
* @return {@link ScheduledThreadPoolExecutor} * @return {@link ScheduledThreadPoolExecutor}
* @since 5.6.5 * @since 5.6.5
@ -602,13 +614,13 @@ public class ThreadUtil {
long initialDelay, long initialDelay,
long period, long period,
TimeUnit timeUnit, TimeUnit timeUnit,
boolean fixedRateOrFixedDelay){ boolean fixedRateOrFixedDelay) {
if(null == executor){ if (null == executor) {
executor = createScheduledExecutor(2); executor = createScheduledExecutor(2);
} }
if(fixedRateOrFixedDelay){ if (fixedRateOrFixedDelay) {
executor.scheduleAtFixedRate(command, initialDelay, period, timeUnit); executor.scheduleAtFixedRate(command, initialDelay, period, timeUnit);
} else{ } else {
executor.scheduleWithFixedDelay(command, initialDelay, period, timeUnit); executor.scheduleWithFixedDelay(command, initialDelay, period, timeUnit);
} }