-
-
Notifications
You must be signed in to change notification settings - Fork 302
/
TimeKeeper.java
71 lines (66 loc) · 2.03 KB
/
TimeKeeper.java
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
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
package dev.utils.common.assist;
/**
* detail: 堵塞时间辅助类
* @author Ttt
*/
public class TimeKeeper {
/**
* 设置等待一段时间后, 通知方法 ( 异步 )
* @param keepTimeMillis 堵塞时间 ( 毫秒 )
* @param callback 结束回调通知
*/
public void waitForEndAsync(
final long keepTimeMillis,
final OnEndCallback callback
) {
if (keepTimeMillis > 0L) {
new Thread(() -> waitForEnd(keepTimeMillis, callback)).start();
}
}
/**
* 设置等待一段时间后, 通知方法 ( 同步 )
* @param keepTimeMillis 堵塞时间 ( 毫秒 )
* @param callback 结束回调通知
*/
public void waitForEnd(
final long keepTimeMillis,
final OnEndCallback callback
) {
if (keepTimeMillis > 0L) {
// 开始堵塞时间
long startTime = System.currentTimeMillis();
try {
// 进行堵塞
Thread.sleep(keepTimeMillis);
// 触发回调
if (callback != null) {
callback.onEnd(keepTimeMillis, startTime, System.currentTimeMillis(), false);
}
} catch (Exception e) {
// 触发回调
if (callback != null) {
callback.onEnd(keepTimeMillis, startTime, System.currentTimeMillis(), true);
}
}
}
}
/**
* detail: 结束通知回调
* @author Ttt
*/
public interface OnEndCallback {
/**
* 结束触发通知方法
* @param keepTimeMillis 堵塞时间 ( 毫秒 )
* @param startTimeMillis 开始堵塞时间 ( 毫秒 )
* @param endTimeMillis 结束时间 ( 毫秒 )
* @param isError 是否发生异常
*/
void onEnd(
long keepTimeMillis,
long startTimeMillis,
long endTimeMillis,
boolean isError
);
}
}