package org.sxkj.common.utils;
|
|
import java.util.Map;
|
import java.util.Optional;
|
import java.util.concurrent.ConcurrentHashMap;
|
import java.util.concurrent.atomic.AtomicInteger;
|
|
/**
|
* 统一间隔执行任务
|
*/
|
public class NumHashMapRecordUtils {
|
/**
|
* 间隔次数map
|
*/
|
private static Map<String, AtomicInteger> INTERVAL_NUM_MAP = new ConcurrentHashMap();
|
|
|
/**
|
* 根据次数执行
|
*
|
* @param id 唯一值
|
* @param intervalNum 间隔执行次数
|
* @param supplier 执行方法
|
*/
|
public static void applyByNum(String id, Integer intervalNum, Runnable supplier) {
|
AtomicInteger atomicInteger = Optional.ofNullable(INTERVAL_NUM_MAP.get(id)).orElse(new AtomicInteger(0));
|
|
if (atomicInteger.get() % intervalNum == 0) {
|
supplier.run();
|
}
|
atomicInteger.incrementAndGet();
|
INTERVAL_NUM_MAP.put(id, atomicInteger);
|
}
|
|
|
}
|
