作者 crossoverJie

:white_check_mark: Adding tests.

... ... @@ -113,7 +113,7 @@ public final class RingBufferWheel {
tasks.add(task);
} else {
int cycleNum = cycleNum(key, bufferSize);
task.setCycleNum(index);
task.setIndex(index);
task.setCycleNum(cycleNum);
Set<Task> sets = new HashSet<>();
sets.add(task);
... ...
package com.crossoverjie.cim.common.data.construct;
import com.google.common.util.concurrent.ThreadFactoryBuilder;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import java.util.concurrent.ScheduledThreadPoolExecutor;
import java.util.concurrent.ThreadFactory;
import java.util.concurrent.TimeUnit;
/**
* Function:
*
* @author crossoverJie
* Date: 2019-10-11 10:41
* @since JDK 1.8
*/
public class ScheduledTest {
private static Logger logger = LoggerFactory.getLogger(ScheduledTest.class) ;
public static void main(String[] args) {
logger.info("start.....");
ThreadFactory scheduled = new ThreadFactoryBuilder()
.setNameFormat("scheduled-%d")
.setDaemon(true)
.build();
ScheduledThreadPoolExecutor scheduledExecutorService = new ScheduledThreadPoolExecutor(1,scheduled) ;
scheduledExecutorService.schedule(() -> logger.info("scheduled........."),3, TimeUnit.SECONDS) ;
}
}
... ...
package com.crossoverjie.cim.common.data.construct;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import java.util.Timer;
import java.util.TimerTask;
/**
* Function:
*
* @author crossoverJie
* Date: 2019-10-09 22:48
* @since JDK 1.8
*/
public class TimerTest {
private static Logger logger = LoggerFactory.getLogger(TimerTest.class) ;
public static void main(String[] args) {
logger.info("start");
Timer timer = new Timer() ;
timer.schedule(new TimerTask() {
@Override
public void run() {
logger.info("test");
}
},50000);
timer.schedule(new TimerTask() {
@Override
public void run() {
logger.info("test");
}
},30000);
}
}
... ...