blob: 0c89f2181d03a0aa0ba2e4108cc4b7d5766da2db (
plain)
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
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
|
package de.torui.coflsky;
import java.util.ConcurrentModificationException;
import java.util.HashMap;
import java.util.Map;
import java.util.Timer;
import java.util.TimerTask;
import java.util.concurrent.ConcurrentHashMap;
public class FlipHandler {
public static class Flip {
public String id;
public int worth;
public Flip(String id, int worth) {
super();
this.id = id;
this.worth = worth;
}
public Flip() {
}
}
public static class FlipDataStructure {
private Map<Long, Flip> Flips = new ConcurrentHashMap <>();
private Map<Flip, Long> ReverseMap = new ConcurrentHashMap <>();
private Flip HighestFlip = null;
private Timer t = new Timer();
private TimerTask CurrentTask = null;
public synchronized void RunHouseKeeping() {
synchronized (Flips) {
Long RemoveAllPrior = System.currentTimeMillis() - (Config.KeepFlipsForSeconds*1000);
Flips.keySet().stream().filter(l -> l <= RemoveAllPrior).forEach(l -> RemoveLong(l));
if (!Flips.isEmpty()) {
HighestFlip = Flips.values().stream().max((f1, f2) -> f1.worth - f2.worth).orElse(null);
} else {
HighestFlip = null;
}
}
if (CurrentTask != null) {
CurrentTask.cancel();
CurrentTask = null;
t.purge();
}
if (!Flips.isEmpty()) {
CurrentTask = new TimerTask() {
@Override
public void run() {
RunHouseKeeping();
}
};
t.schedule(CurrentTask, Config.KeepFlipsForSeconds * 1000 + /* small arbitrary delay */150);
}
}
public synchronized void Insert(Flip flip) {
Long l = System.currentTimeMillis();
synchronized(Flips) {
Flips.put(l, flip);
ReverseMap.put(flip, l);
}
RunHouseKeeping();
}
private void RemoveLong(Long l) {
if (l == null)
return;
synchronized(Flips) {
Flip f = Flips.get(l);
if (f != null) {
ReverseMap.remove(f);
Flips.remove(l);
}
}
}
private void RemoveFlip(Flip f) {
if (f == null)
return;
synchronized(Flips) {
Long l = ReverseMap.get(f);
if (l != null) {
Flips.remove(l);
ReverseMap.remove(f);
}
}
}
public Flip GetHighestFlip() {
return HighestFlip;
}
public void InvalidateFlip(Flip flip) {
RemoveFlip(flip);
RunHouseKeeping();
}
public int CurrentFlips() {
return Flips.size();
}
}
public FlipDataStructure fds;
public FlipHandler() {
fds = new FlipDataStructure();
}
}
|
