.
This commit is contained in:
commit
90de9c7bd9
42
.gitignore
vendored
Normal file
42
.gitignore
vendored
Normal file
@ -0,0 +1,42 @@
|
||||
*.iml
|
||||
.idea/
|
||||
.ipr
|
||||
.iws
|
||||
*~
|
||||
~*
|
||||
*.diff
|
||||
*.patch
|
||||
*.bak
|
||||
.DS_Store
|
||||
Thumbs.db
|
||||
.svn/
|
||||
*.swp
|
||||
.nojekyll
|
||||
.project
|
||||
.settings/
|
||||
|
||||
|
||||
#==========================
|
||||
*.class
|
||||
|
||||
# Mobile Tools for Java (J2ME)
|
||||
.mtj.tmp/
|
||||
|
||||
# Package Files #
|
||||
*.war
|
||||
*.ear
|
||||
|
||||
#=======================
|
||||
target
|
||||
.idea
|
||||
*.iml
|
||||
*.log
|
||||
logs
|
||||
*.iws
|
||||
*.classpath
|
||||
.DS_Store
|
||||
*.patch
|
||||
~$*
|
||||
|
||||
*.MF
|
||||
tem
|
||||
32
pom.xml
Normal file
32
pom.xml
Normal file
@ -0,0 +1,32 @@
|
||||
<?xml version="1.0" encoding="UTF-8"?>
|
||||
<project xmlns="http://maven.apache.org/POM/4.0.0"
|
||||
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
|
||||
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
|
||||
<modelVersion>4.0.0</modelVersion>
|
||||
|
||||
<groupId>groupId</groupId>
|
||||
<artifactId>redtimer</artifactId>
|
||||
<version>1.0-SNAPSHOT</version>
|
||||
<dependencies>
|
||||
<dependency>
|
||||
<groupId>junit</groupId>
|
||||
<artifactId>junit</artifactId>
|
||||
<version>4.12</version>
|
||||
<scope>compile</scope>
|
||||
</dependency>
|
||||
</dependencies>
|
||||
|
||||
<build>
|
||||
<plugins>
|
||||
<plugin>
|
||||
<groupId>org.apache.maven.plugins</groupId>
|
||||
<artifactId>maven-compiler-plugin</artifactId>
|
||||
<configuration>
|
||||
<source>1.8</source>
|
||||
<target>1.8</target>
|
||||
</configuration>
|
||||
</plugin>
|
||||
</plugins>
|
||||
</build>
|
||||
|
||||
</project>
|
||||
497
src/main/java/com/lxyer/timer/Task.java
Normal file
497
src/main/java/com/lxyer/timer/Task.java
Normal file
@ -0,0 +1,497 @@
|
||||
package com.lxyer.timer;
|
||||
|
||||
import java.text.SimpleDateFormat;
|
||||
import java.time.LocalDate;
|
||||
import java.time.LocalDateTime;
|
||||
import java.time.ZoneOffset;
|
||||
import java.util.ArrayList;
|
||||
import java.util.Arrays;
|
||||
import java.util.List;
|
||||
|
||||
/**
|
||||
* Created by liangxianyou at 2018/7/23 14:33.
|
||||
*/
|
||||
public abstract class Task implements Runnable {
|
||||
protected String name;
|
||||
protected long nextTime;
|
||||
private TimerScheduled timerScheduled;
|
||||
public abstract void run();
|
||||
|
||||
public Task(String name, String cfg){
|
||||
this.name = name;
|
||||
LocalDateTime now = LocalDateTime.now();
|
||||
timerScheduled = new TimerScheduled(now.getYear(), now.getMonthValue(), cfg);
|
||||
nextTime = timerScheduled.nextTime.toInstant(ZoneOffset.of("+8")).toEpochMilli();
|
||||
}
|
||||
|
||||
public long nextTime(){
|
||||
LocalDateTime next = timerScheduled.nextTime();
|
||||
this.nextTime = next.toInstant(ZoneOffset.of("+8")).toEpochMilli();
|
||||
return nextTime;
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* 时间解析器
|
||||
*/
|
||||
@SuppressWarnings("Duplicates")
|
||||
class TimerScheduled {
|
||||
private int year;
|
||||
private int month;
|
||||
private int[] minutes;
|
||||
private int[] hours;
|
||||
private int[] days;
|
||||
private int[] monthes;
|
||||
private int[] weeks;
|
||||
String[] cfgArr;
|
||||
|
||||
LocalDateTime nextTime;
|
||||
private int _y,_M,_d,_H,_m;
|
||||
|
||||
public TimerScheduled(int year, int month, String cfg) {
|
||||
this.year = year;
|
||||
this.month = month;
|
||||
this.cfgArr = cfg.split(" ");
|
||||
|
||||
setWeeks();
|
||||
setMonthes();
|
||||
setDays();
|
||||
setHours();
|
||||
setMinutes();
|
||||
|
||||
//寻找初始合法时间
|
||||
LocalDateTime now = LocalDateTime.now();
|
||||
_y = now.getYear();
|
||||
_M= now.getMonthValue();
|
||||
_d= now.getDayOfMonth();
|
||||
_H= now.getHour();
|
||||
_m= now.getMinute();
|
||||
|
||||
String cmd = "";//y M d H m
|
||||
if (days.length == 0) cmd = "M";
|
||||
do {
|
||||
carry(cmd);
|
||||
int inx;
|
||||
if ((inx = nowOk(monthes, _M)) < 0){
|
||||
cmd = "y";
|
||||
continue;
|
||||
}
|
||||
_M = monthes[inx];
|
||||
|
||||
if ((inx = nowOk(days, _d)) < 0){
|
||||
cmd = "M";
|
||||
continue;
|
||||
}
|
||||
_d = days[inx];
|
||||
|
||||
if ((inx = nowOk(hours, _H)) < 0){
|
||||
cmd = "d";
|
||||
continue;
|
||||
}
|
||||
_H = hours[inx];
|
||||
|
||||
if ((inx = nowOk(minutes, _m)) < 0){
|
||||
cmd = "H";
|
||||
continue;
|
||||
}
|
||||
_m = minutes[inx];
|
||||
break;
|
||||
}while (true);
|
||||
|
||||
if (_y == now.getYear() && _M == now.getMonthValue() && _d == now.getDayOfMonth()
|
||||
&& _H == now.getHour() && _m == now.getMinute()){
|
||||
carry("m");
|
||||
}
|
||||
|
||||
nextTime = LocalDateTime.of(_y, _M, _d, _H, _m);
|
||||
System.out.println(cfg);
|
||||
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
|
||||
System.out.println("init:"+ sdf.format(nextTime.toInstant(ZoneOffset.of("+8")).toEpochMilli()));
|
||||
}
|
||||
|
||||
/**
|
||||
* 下一次执行的时间
|
||||
* @return
|
||||
*/
|
||||
protected LocalDateTime nextTime(){
|
||||
|
||||
String cmd = "m";
|
||||
carry(cmd);
|
||||
nextTime = LocalDateTime.of(year, month
|
||||
, _d == -1? nextTime.getDayOfMonth() : _d
|
||||
, _H == -1? nextTime.getHour() : _H
|
||||
, _m == -1? nextTime.getMinute() : _m);
|
||||
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
|
||||
System.out.println("下次执行:"+ sdf.format(nextTime.toInstant(ZoneOffset.of("+8")).toEpochMilli()));
|
||||
return nextTime;
|
||||
}
|
||||
|
||||
/**
|
||||
* 通过发送指令进行进位
|
||||
* @param cmd 进位指令
|
||||
*/
|
||||
private void carry(String cmd){
|
||||
int inx;
|
||||
while (!"".equals(cmd)){
|
||||
switch (cmd) {
|
||||
case "y":
|
||||
_y = this.year = ++_y;
|
||||
_M = this.month = monthes[0];
|
||||
setDays();
|
||||
if (days.length == 0){
|
||||
cmd = "M";
|
||||
continue;
|
||||
}
|
||||
_d = days[0];
|
||||
_H = hours[0];
|
||||
_m = minutes[0];
|
||||
break;
|
||||
case "M":
|
||||
if (_M < monthes[0]){
|
||||
_M = monthes[0];
|
||||
break;
|
||||
}
|
||||
inx = Arrays.binarySearch(monthes, _M);
|
||||
if (inx < 0 || inx >= monthes.length-1) {
|
||||
cmd = "y";
|
||||
continue ;
|
||||
}
|
||||
_M = this.month = monthes[inx+1];
|
||||
setDays();
|
||||
if (days.length == 0){
|
||||
cmd = "M";
|
||||
continue;
|
||||
}
|
||||
_d = days[0];
|
||||
_H = hours[0];
|
||||
_m = minutes[0];
|
||||
break;
|
||||
case "d":
|
||||
if (_d < days[0]){
|
||||
_d = days[0];
|
||||
break;
|
||||
}
|
||||
inx = Arrays.binarySearch(days, _d);
|
||||
if (inx < 0 || inx >= days.length-1) {
|
||||
cmd = "M";
|
||||
continue ;
|
||||
}
|
||||
_d = days[inx+1];
|
||||
_H = hours[0];
|
||||
_m = minutes[0];
|
||||
break;
|
||||
case "H":
|
||||
if (_H < hours[0]){
|
||||
_H = hours[0];
|
||||
break;
|
||||
}
|
||||
inx = Arrays.binarySearch(hours, _H);
|
||||
if (inx < 0 || inx >= hours.length -1) {
|
||||
cmd = "d";
|
||||
continue ;
|
||||
}
|
||||
_H = hours[inx+1];
|
||||
_m = minutes[0];
|
||||
break;
|
||||
case "m":
|
||||
if (_m < minutes[0]){
|
||||
_m = minutes[0];
|
||||
break;
|
||||
}
|
||||
inx = Arrays.binarySearch(minutes, _m);
|
||||
if (inx < 0 || inx >= minutes.length -1) {
|
||||
cmd = "H";
|
||||
continue ;
|
||||
}
|
||||
_m = minutes[inx+1];
|
||||
break;
|
||||
}
|
||||
cmd = "";
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* 得到初始合法时间的索引
|
||||
* @param arr 合法时间序列
|
||||
* @param n 初始选中值
|
||||
* @return 合法时间的索引
|
||||
*/
|
||||
private int nowOk(int[] arr, int n){
|
||||
if (arr == null || arr.length == 0) return -1;
|
||||
if (arr[0] > n)
|
||||
return 0;
|
||||
if (arr[arr.length-1] < n)
|
||||
return -1;
|
||||
if (arr[arr.length-1] == n)
|
||||
return arr.length-1;
|
||||
|
||||
for (int i = 0; i < arr.length-1; i++) {
|
||||
if ((arr[i] < n && arr[i+1] > n) || arr[i] == n){
|
||||
return i;
|
||||
}
|
||||
}
|
||||
|
||||
return -1;
|
||||
}
|
||||
|
||||
/** 以下为 初始化合法时间 weeks，monthes，days，hour，minutes 序列 */
|
||||
private void setMinutes(){
|
||||
String cfg = cfgArr[0];
|
||||
if ("*".equals(cfg)){//*
|
||||
minutes = new int[60];
|
||||
for (int i = 0; i < 60; i++) {
|
||||
minutes[i] = i;
|
||||
}
|
||||
} else if (cfg.matches("^[0-5]??[0-9]??$")){//n
|
||||
minutes = new int[1];
|
||||
minutes[0] = Integer.parseInt(cfg);
|
||||
}else if (cfg.matches("^[*]/[0-9]+$")){// */5
|
||||
String[] strArr = cfg.split("/");
|
||||
int p = Integer.parseInt(strArr[1]);
|
||||
minutes = new int[60/p];
|
||||
for (int i = 0; i < minutes.length; i++) {
|
||||
minutes[i] = i*p;
|
||||
}
|
||||
}else if (cfg.matches("^([0-5]??[0-9]??,)+([0-5]??[0-9]??)?$")){//1,3
|
||||
String[] strings = cfg.split(",");
|
||||
minutes = new int[strings.length];
|
||||
for (int i = 0; i < strings.length; i++) {
|
||||
minutes[i] = Integer.parseInt(strings[i]);
|
||||
}
|
||||
}else if (cfg.matches("^[0-5]??[0-9]??\\-[0-5]??[0-9]??$")){//1-3
|
||||
String[] split = cfg.split("-");
|
||||
int s = Integer.parseInt(split[0]);
|
||||
int e = Integer.parseInt(split[1]);
|
||||
|
||||
minutes = new int[e-s +1];
|
||||
for (int i = 0; i < minutes.length; i++) {
|
||||
minutes[i] = s+i;
|
||||
}
|
||||
}else if (cfg.matches("^[0-5]??[0-9]??\\-[0-5]??[0-9]??/[0-5]??[0-9]??$")){//3-18/5
|
||||
String[] strArr = cfg.split("/");
|
||||
String[] str2Arr = strArr[0].split("-");
|
||||
int s = Integer.parseInt(str2Arr[0]);
|
||||
int e = Integer.parseInt(str2Arr[1]);
|
||||
int p = Integer.parseInt(strArr[1]);
|
||||
|
||||
minutes = new int[(e-s)/p];
|
||||
for (int i = 0; i < minutes.length; i++) {
|
||||
minutes[i] = s + i*p;
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
private void setHours(){
|
||||
String cfg = cfgArr[1];
|
||||
if ("*".equals(cfg)){//*
|
||||
hours = new int[24];
|
||||
for (int i = 0; i < hours.length; i++) {
|
||||
hours[i] = i;
|
||||
}
|
||||
} else if (cfg.matches("^[0-5]??[0-9]??$")){//n
|
||||
hours = new int[1];
|
||||
hours[0] = Integer.parseInt(cfg);
|
||||
}else if (cfg.matches("^[*]/[0-9]+$")){// */5
|
||||
String[] strArr = cfg.split("/");
|
||||
int p = Integer.parseInt(strArr[1]);
|
||||
hours = new int[24/p];
|
||||
for (int i = 0; i < hours.length; i++) {
|
||||
hours[i] = i*p;
|
||||
}
|
||||
}else if (cfg.matches("^([0-5]??[0-9]??,)+([0-5]??[0-9]??)?$")){//1,3
|
||||
String[] strArr = cfg.split(",");
|
||||
hours = new int[strArr.length];
|
||||
for (int i = 0; i < strArr.length; i++) {
|
||||
hours[i] = Integer.parseInt(strArr[i]);
|
||||
}
|
||||
}else if (cfg.matches("^[0-5]??[0-9]??\\-[0-5]??[0-9]??$")){//1-3
|
||||
String[] split = cfg.split("-");
|
||||
int s = Integer.parseInt(split[0]);
|
||||
int e = Integer.parseInt(split[1]);
|
||||
|
||||
hours = new int[e-s +1];
|
||||
for (int i = 0; i < hours.length; i++) {
|
||||
hours[i] = s+i;
|
||||
}
|
||||
}else if (cfg.matches("^[0-5]??[0-9]??\\-[0-5]??[0-9]??/[0-5]??[0-9]??$")){//3-18/5
|
||||
String[] strArr = cfg.split("/");
|
||||
String[] str2Arr = strArr[0].split("-");
|
||||
int s = Integer.parseInt(str2Arr[0]);
|
||||
int e = Integer.parseInt(str2Arr[1]);
|
||||
int p = Integer.parseInt(strArr[1]);
|
||||
|
||||
hours = new int[(e-s)/p];
|
||||
for (int i = 0; i < hours.length; i++) {
|
||||
hours[i] = s + i*p;
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
private void setWeeks(){
|
||||
String cfg = cfgArr[4];
|
||||
if ("*".equals(cfg)){//*
|
||||
weeks = new int[7];
|
||||
for (int i = 0; i < weeks.length; i++) {
|
||||
weeks[i] = i+1;
|
||||
}
|
||||
} else if (cfg.matches("^[0-5]??[0-9]??$")){//n
|
||||
weeks = new int[1];
|
||||
weeks[0] = Integer.parseInt(cfg);
|
||||
}else if (cfg.matches("^[*]/[0-9]+$")){// */5
|
||||
String[] strArr = cfg.split("/");
|
||||
int p = Integer.parseInt(strArr[1]);
|
||||
weeks = new int[7/p];
|
||||
for (int i = 0; i < weeks.length; i++) {
|
||||
weeks[i] = i*p;
|
||||
}
|
||||
}else if (cfg.matches("^([0-5]??[0-9]??,)+([0-5]??[0-9]??)?$")){//1,3
|
||||
String[] strArr = cfg.split(",");
|
||||
weeks = new int[strArr.length];
|
||||
for (int i = 0; i < strArr.length; i++) {
|
||||
weeks[i] = Integer.parseInt(strArr[i]);
|
||||
}
|
||||
}else if (cfg.matches("^[0-5]??[0-9]??\\-[0-5]??[0-9]??$")){//1-3
|
||||
String[] split = cfg.split("-");
|
||||
int s = Integer.parseInt(split[0]);
|
||||
int e = Integer.parseInt(split[1]);
|
||||
|
||||
weeks = new int[e-s +1];
|
||||
for (int i = 0; i < weeks.length; i++) {
|
||||
weeks[i] = s+i;
|
||||
}
|
||||
}else if (cfg.matches("^[0-5]??[0-9]??\\-[0-5]??[0-9]??/[0-5]??[0-9]??$")){//3-18/5
|
||||
String[] strArr = cfg.split("/");
|
||||
String[] str2Arr = strArr[0].split("-");
|
||||
int s = Integer.parseInt(str2Arr[0]);
|
||||
int e = Integer.parseInt(str2Arr[1]);
|
||||
int p = Integer.parseInt(strArr[1]);
|
||||
|
||||
weeks = new int[(e-s)/p];
|
||||
for (int i = 0; i < weeks.length; i++) {
|
||||
weeks[i] = s + i*p;
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
private void setMonthes(){
|
||||
String cfg = cfgArr[3];
|
||||
if ("*".equals(cfg)){//*
|
||||
monthes = new int[12];
|
||||
for (int i = 0; i < monthes.length; i++) {
|
||||
monthes[i] = i+1;
|
||||
}
|
||||
} else if (cfg.matches("^[0-5]??[0-9]??$")){//n
|
||||
monthes = new int[1];
|
||||
monthes[0] = Integer.parseInt(cfg);
|
||||
}else if (cfg.matches("^[*]/[0-9]+$")){// */5
|
||||
String[] strArr = cfg.split("/");
|
||||
int p = Integer.parseInt(strArr[1]);
|
||||
monthes = new int[12/p];
|
||||
for (int i = 0; i < monthes.length; i++) {
|
||||
monthes[i] = i*p;
|
||||
}
|
||||
}else if (cfg.matches("^([0-5]??[0-9]??,)+([0-5]??[0-9]??)?$")){//1,3
|
||||
String[] strArr = cfg.split(",");
|
||||
monthes = new int[strArr.length];
|
||||
for (int i = 0; i < strArr.length; i++) {
|
||||
monthes[i] = Integer.parseInt(strArr[i]);
|
||||
}
|
||||
}else if (cfg.matches("^[0-5]??[0-9]??\\-[0-5]??[0-9]??$")){//1-3
|
||||
String[] split = cfg.split("-");
|
||||
int s = Integer.parseInt(split[0]);
|
||||
int e = Integer.parseInt(split[1]);
|
||||
|
||||
monthes = new int[e-s +1];
|
||||
for (int i = 0; i < monthes.length; i++) {
|
||||
monthes[i] = s+i;
|
||||
}
|
||||
}else if (cfg.matches("^[0-5]??[0-9]??\\-[0-5]??[0-9]??/[0-5]??[0-9]??$")){//3-18/5
|
||||
String[] strArr = cfg.split("/");
|
||||
String[] str2Arr = strArr[0].split("-");
|
||||
int s = Integer.parseInt(str2Arr[0]);
|
||||
int e = Integer.parseInt(str2Arr[1]);
|
||||
int p = Integer.parseInt(strArr[1]);
|
||||
|
||||
monthes = new int[(e-s)/p];
|
||||
for (int i = 0; i < monthes.length; i++) {
|
||||
monthes[i] = s + i*p;
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
private void setDays(){
|
||||
String cfg = cfgArr[2];
|
||||
//当前月份总天数，
|
||||
LocalDate firstDay = LocalDate.of(year, month, 1);
|
||||
int lengthOfMonth = firstDay.lengthOfMonth();
|
||||
|
||||
if ("*".equals(cfg)){//*
|
||||
days = new int[lengthOfMonth];
|
||||
for (int i = 0; i < days.length; i++) {
|
||||
days[i] = i+1;
|
||||
}
|
||||
} else if (cfg.matches("^[0-5]??[0-9]??$")){//n
|
||||
days = new int[1];
|
||||
days[0] = Integer.parseInt(cfg);
|
||||
}else if (cfg.matches("^[*]/[0-9]+$")){// */5
|
||||
String[] strArr = cfg.split("/");
|
||||
int p = Integer.parseInt(strArr[1]);
|
||||
days = new int[lengthOfMonth/p];
|
||||
for (int i = 0; i < days.length; i++) {
|
||||
days[i] = i*p;
|
||||
}
|
||||
}else if (cfg.matches("^([0-5]??[0-9]??,)+([0-5]??[0-9]??)?$")){//1,3
|
||||
String[] strArr = cfg.split(",");
|
||||
days = new int[strArr.length];
|
||||
for (int i = 0; i < strArr.length; i++) {
|
||||
days[i] = Integer.parseInt(strArr[i]);
|
||||
}
|
||||
}else if (cfg.matches("^[0-5]??[0-9]??\\-[0-5]??[0-9]??$")){//1-3
|
||||
String[] split = cfg.split("-");
|
||||
int s = Integer.parseInt(split[0]);
|
||||
int e = Integer.parseInt(split[1]);
|
||||
|
||||
days = new int[e-s +1];
|
||||
for (int i = 0; i < days.length; i++) {
|
||||
days[i] = s+i;
|
||||
}
|
||||
}else if (cfg.matches("^[0-5]??[0-9]??\\-[0-5]??[0-9]??/[0-5]??[0-9]??$")){//3-18/5
|
||||
String[] strArr = cfg.split("/");
|
||||
String[] str2Arr = strArr[0].split("-");
|
||||
int s = Integer.parseInt(str2Arr[0]);
|
||||
int e = Integer.parseInt(str2Arr[1]);
|
||||
int p = Integer.parseInt(strArr[1]);
|
||||
|
||||
days = new int[(e-s)/p];
|
||||
for (int i = 0; i < days.length; i++) {
|
||||
days[i] = s + i*p;
|
||||
}
|
||||
}
|
||||
|
||||
int firstWeek = firstDay.getDayOfWeek().getValue();
|
||||
List<Integer> allDay = new ArrayList<>();
|
||||
for (int i = 0; i < days.length; i++) {
|
||||
//int week = 7 - Math.abs(i - firstWeek) % 7;//当前星期X
|
||||
int week;
|
||||
int d = days[i];
|
||||
if (d + firstWeek <= 8){
|
||||
week = firstWeek + d - 1;
|
||||
}else {
|
||||
week = (d - (8-firstWeek))%7;
|
||||
if (week == 0) week = 7;
|
||||
}
|
||||
|
||||
//System.out.printf("M:%s,d:%s,w:%s%n", month, d, week);
|
||||
|
||||
if (Arrays.binarySearch(weeks, week) > -1){
|
||||
allDay.add(d);//加入日期
|
||||
}
|
||||
}
|
||||
|
||||
days = new int[allDay.size()];
|
||||
for (int i = 0; i < allDay.size(); i++) {
|
||||
days[i] = allDay.get(i);
|
||||
}
|
||||
}
|
||||
|
||||
}
|
||||
126
src/main/java/com/lxyer/timer/TimerExecutor.java
Normal file
126
src/main/java/com/lxyer/timer/TimerExecutor.java
Normal file
@ -0,0 +1,126 @@
|
||||
package com.lxyer.timer;
|
||||
|
||||
import java.util.Arrays;
|
||||
import java.util.HashSet;
|
||||
import java.util.Set;
|
||||
import java.util.concurrent.ExecutorService;
|
||||
import java.util.concurrent.Executors;
|
||||
|
||||
/**
|
||||
* Created by liangxianyou at 2018/7/23 14:07.
|
||||
*/
|
||||
public class TimerExecutor {
|
||||
private TimerQueue queue = new TimerQueue();
|
||||
private ExecutorService executor;
|
||||
|
||||
/**
|
||||
* 创建定时调度器
|
||||
* @param n 调度线程数
|
||||
*/
|
||||
public TimerExecutor(int n) {
|
||||
executor = Executors.newFixedThreadPool(n);
|
||||
}
|
||||
|
||||
public void add(Task task){
|
||||
queue.put(task);
|
||||
}
|
||||
private void add(Task task, boolean upTime){
|
||||
if (upTime) task.nextTime();
|
||||
queue.put(task);
|
||||
}
|
||||
|
||||
/**
|
||||
* 启动定时调度
|
||||
*/
|
||||
public void start() {
|
||||
new Thread(()->{
|
||||
while (true){
|
||||
try{
|
||||
Task take = null;
|
||||
try {
|
||||
take = queue.take();
|
||||
} catch (InterruptedException e) {
|
||||
e.printStackTrace();
|
||||
}
|
||||
|
||||
executor.execute(take);
|
||||
add(take, true);
|
||||
}catch (Exception e){
|
||||
e.printStackTrace();
|
||||
}
|
||||
}
|
||||
}).start();
|
||||
}
|
||||
}
|
||||
|
||||
class TimerQueue{
|
||||
Object lock = new Object();
|
||||
Task[] queue = new Task[128];
|
||||
Set<String> names = new HashSet<>();
|
||||
int size=0;
|
||||
|
||||
void put(Task task) {
|
||||
remove(task.name);
|
||||
synchronized (lock){
|
||||
int inx = size;//目标坐标
|
||||
while (inx > 0 && queue[inx-1].nextTime > task.nextTime ){
|
||||
inx--;
|
||||
}
|
||||
|
||||
if (queue.length == size+1)
|
||||
queue = Arrays.copyOf(queue, size * 2);
|
||||
|
||||
for (int i = size+1; i > inx; i--) {
|
||||
queue[i] = queue[i-1];
|
||||
queue[i-1] = null;
|
||||
}
|
||||
queue[inx] = task;
|
||||
|
||||
size++;
|
||||
names.add(task.name);
|
||||
lock.notify();
|
||||
}
|
||||
}
|
||||
|
||||
Task take() throws InterruptedException {
|
||||
synchronized (lock){
|
||||
if (size == 0) lock.wait();
|
||||
|
||||
long currentTime = System.currentTimeMillis();
|
||||
long nextTime = queue[0].nextTime;
|
||||
|
||||
if (currentTime >= nextTime){
|
||||
Task task = queue[0];
|
||||
for (int i = 0; i < size;i++) {
|
||||
queue[i] = queue[i+1];
|
||||
}
|
||||
queue[size-1] = null;
|
||||
size--;
|
||||
return task;
|
||||
}else {
|
||||
lock.wait(nextTime - currentTime);
|
||||
return take();
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
Task remove(String name){
|
||||
synchronized (lock){
|
||||
if(!names.contains(name)) return null;
|
||||
|
||||
Task take = null;
|
||||
for (int i = 0; i < size-1; i++) {
|
||||
if (name.equals(queue[i].name)){
|
||||
take = queue[i];
|
||||
while (i < size+1){
|
||||
queue[i] = queue[i+1];
|
||||
queue[i+1] = null;
|
||||
}
|
||||
names.remove(name);
|
||||
break;
|
||||
}
|
||||
}
|
||||
return take;
|
||||
}
|
||||
}
|
||||
}
|
||||
186
src/test/java/com/lxyer/timer/TimerTest.java
Normal file
186
src/test/java/com/lxyer/timer/TimerTest.java
Normal file
@ -0,0 +1,186 @@
|
||||
package com.lxyer.timer;
|
||||
|
||||
import org.junit.Test;
|
||||
|
||||
import java.text.SimpleDateFormat;
|
||||
import java.time.LocalDateTime;
|
||||
|
||||
/**
|
||||
* t2 测试定时器加入任务的调度管理
|
||||
* t6 测试时间表达式配置校验
|
||||
* 其他测试用例
|
||||
* Created by liangxianyou at 2018/7/19 17:19.
|
||||
*/
|
||||
@SuppressWarnings("Duplicates")
|
||||
public class TimerTest {
|
||||
|
||||
/**
|
||||
* 启动定时器测试，
|
||||
*/
|
||||
@Test
|
||||
public void t2(){
|
||||
TimerExecutor timerExecutor = new TimerExecutor(1);
|
||||
|
||||
timerExecutor.add(new Task("a1", "1-40 * * * *") {
|
||||
@Override
|
||||
public void run() {
|
||||
ThreadLocal<SimpleDateFormat> local = new ThreadLocal<>();
|
||||
SimpleDateFormat sdf = local.get();
|
||||
if (sdf == null){
|
||||
sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
|
||||
}
|
||||
System.out.printf("执行任务:%s now:%s, %n", name, sdf.format(System.currentTimeMillis()));
|
||||
}
|
||||
});
|
||||
|
||||
timerExecutor.start();
|
||||
|
||||
try {
|
||||
Thread.sleep(1500_000000);
|
||||
} catch (InterruptedException e) {
|
||||
e.printStackTrace();
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* 测试给配置的时间 加1分钟
|
||||
*/
|
||||
@Test
|
||||
public void t3(){
|
||||
|
||||
// MM-dd HH:mm:ss
|
||||
//0 2 * * *
|
||||
//0-59 0-23 1-31(L) 1-12 0-6
|
||||
|
||||
LocalDateTime now = LocalDateTime.now();
|
||||
LocalDateTime start = LocalDateTime.now();
|
||||
LocalDateTime next = null;
|
||||
|
||||
String str = "8 18 * 7,8 4";
|
||||
String[] ss = str.split(" ");
|
||||
for (String s : ss) System.out.println(s);
|
||||
System.out.println("----------");
|
||||
//Minute * 1,3 1-3 */5 3-15/5 5
|
||||
String minute = ss[0];
|
||||
|
||||
if ("*".equals(minute)){//*
|
||||
next = start.plusMinutes(1);
|
||||
} else if (minute.matches("^[0-5]??[0-9]??$")){//n
|
||||
next = LocalDateTime.of(start.getYear(),
|
||||
start.getMonth(),
|
||||
start.getDayOfMonth(),
|
||||
start.getHour(),
|
||||
Integer.parseInt(minute));
|
||||
}else if (minute.matches("^[*]/[0-9]+$")){// */5
|
||||
next = start.plusMinutes(Integer.parseInt(minute.replace("*/","")));
|
||||
}else if (minute.matches("^([0-5]??[0-9]??,)+([0-5]??[0-9]??)? $")){//1,3
|
||||
String[] minutes = minute.split(",");
|
||||
int inx=0;
|
||||
for (int i = 0; i < minutes.length-1; i++) {
|
||||
if (start.getMinute() >= Integer.parseInt(minutes[i]) && start.getMinute()< Integer.parseInt(minutes[i+1])){
|
||||
inx = i+1;
|
||||
}
|
||||
}
|
||||
next = LocalDateTime.of(start.getYear(),
|
||||
start.getMonth(),
|
||||
start.getDayOfMonth(),
|
||||
start.getHour(),
|
||||
Integer.parseInt(minutes[inx]));
|
||||
}else if (minute.matches("^[0-5]??[0-9]??\\-[0-5]??[0-9]??$")){//1-3
|
||||
int m = start.getMinute();
|
||||
String[] split = minute.split("-");
|
||||
int s = Integer.parseInt(split[0]);
|
||||
int e = Integer.parseInt(split[1]);
|
||||
|
||||
if (m < s || m > e){
|
||||
m = s;
|
||||
}else{
|
||||
m = (m+1) < 60 ? (m+1) : 0;
|
||||
}
|
||||
next = LocalDateTime.of(start.getYear(),
|
||||
start.getMonth(),
|
||||
start.getDayOfMonth(),
|
||||
start.getHour(),
|
||||
m);
|
||||
}else if (minute.matches("^[0-5]??[0-9]??\\-[0-5]??[0-9]??/[0-5]??[0-9]??$")){//3-18/5
|
||||
//
|
||||
}
|
||||
|
||||
System.out.println(next.getMinute());
|
||||
}
|
||||
|
||||
/**
|
||||
* 测试各种正则表达式的合法性
|
||||
*/
|
||||
@Test
|
||||
public void t4(){
|
||||
//Pattern pattern = Pattern.compile();
|
||||
//Minute * 1,3 1-3 */5 3-15/5
|
||||
|
||||
//System.out.println("05".matches("^[0-5]??[0-9]??$"));
|
||||
//System.out.println("*/5".matches("^[*]/[0-9]+$"));
|
||||
//System.out.println("1,5,10,59".matches("^([0-5]??[0-9]??,)+([0-5]??[0-9]??)?$"));
|
||||
//System.out.println("1-3".matches("^[0-5]??[0-9]??\\-[0-5]??[0-9]??$"));
|
||||
//System.out.println("3-18/5".matches("^[0-5]??[0-9]??\\-[0-5]??[0-9]??/[0-5]??[0-9]??$"));
|
||||
|
||||
String str = "01-05/5";// * 1,3 1-3 */5 3-15/5
|
||||
System.out.println(str.matches("^[0-5]??[0-9]??$"));
|
||||
System.out.println(str.matches("^[*]/[0-9]+$"));
|
||||
System.out.println(str.matches("^([0-5]??[0-9]??,)+([0-5]??[0-9]??)?$"));
|
||||
System.out.println(str.matches("^[0-5]??[0-9]??\\-[0-5]??[0-9]??$"));
|
||||
System.out.println(str.matches("^[0-5]??[0-9]??\\-[0-5]??[0-9]??/[0-5]??[0-9]??$"));
|
||||
|
||||
}
|
||||
|
||||
/**
|
||||
* LocalDateTime的一些api测试
|
||||
*/
|
||||
@Test
|
||||
public void t5(){
|
||||
//Minute * 1,3 1-3 */5 3-15/5
|
||||
String cfg = "* * * * *";
|
||||
LocalDateTime time = LocalDateTime.of(2018, 7, 18, 11, 11);
|
||||
|
||||
int minute = time.getMinute();
|
||||
int hour = time.getHour();
|
||||
int day = time.getDayOfMonth();
|
||||
int month = time.getMonthValue();
|
||||
int week = time.getDayOfWeek().getValue();
|
||||
|
||||
//checkCfg
|
||||
//if (month)
|
||||
System.out.println(week);
|
||||
}
|
||||
|
||||
/**
|
||||
* 测试配置的表达式
|
||||
*/
|
||||
@Test
|
||||
public void t6(){
|
||||
//分 时 日 月 周
|
||||
/*
|
||||
08 18 * 7,8 4
|
||||
*/
|
||||
new Task("task1", "1 22-23 * * 7") {
|
||||
@Override
|
||||
public void run() {
|
||||
System.out.println("----");
|
||||
System.out.println(new SimpleDateFormat("0: yyyy-MM-dd HH:mm:ss").format(nextTime));
|
||||
System.out.println(new SimpleDateFormat("1: yyyy-MM-dd HH:mm:ss").format(nextTime()));
|
||||
System.out.println(new SimpleDateFormat("2: yyyy-MM-dd HH:mm:ss").format(nextTime()));
|
||||
System.out.println(new SimpleDateFormat("3: yyyy-MM-dd HH:mm:ss").format(nextTime()));
|
||||
System.out.println(new SimpleDateFormat("4: yyyy-MM-dd HH:mm:ss").format(nextTime()));
|
||||
System.out.println(new SimpleDateFormat("5: yyyy-MM-dd HH:mm:ss").format(nextTime()));
|
||||
System.out.println(new SimpleDateFormat("6: yyyy-MM-dd HH:mm:ss").format(nextTime()));
|
||||
System.out.println(new SimpleDateFormat("7: yyyy-MM-dd HH:mm:ss").format(nextTime()));
|
||||
System.out.println(new SimpleDateFormat("8: yyyy-MM-dd HH:mm:ss").format(nextTime()));
|
||||
System.out.println(new SimpleDateFormat("9: yyyy-MM-dd HH:mm:ss").format(nextTime()));
|
||||
System.out.println(new SimpleDateFormat("10: yyyy-MM-dd HH:mm:ss").format(nextTime()));
|
||||
System.out.println(new SimpleDateFormat("11: yyyy-MM-dd HH:mm:ss").format(nextTime()));
|
||||
System.out.println(new SimpleDateFormat("12: yyyy-MM-dd HH:mm:ss").format(nextTime()));
|
||||
System.out.println(new SimpleDateFormat("13: yyyy-MM-dd HH:mm:ss").format(nextTime()));
|
||||
}
|
||||
}.run();
|
||||
|
||||
}
|
||||
}
|
||||
3
src/test/java/package-info.java
Normal file
3
src/test/java/package-info.java
Normal file
@ -0,0 +1,3 @@
|
||||
/**
|
||||
* Created by liangxianyou at 2018/7/30 0:25.
|
||||
*/
|
||||
Loading…
Reference in New Issue
Block a user