недавно работаю с ScheduleTask и у меня такой вопрос.Я хочу, чтобы мой ScheduleTask удалял элементы с моей карты каждые 5 секунд, если размер карты превышает MAX_SIZE
поле.Я пытаюсь сделать это так:
public class RemoverThread extends TimerTask {
private AbstractCustomCache customCache;
private static final int MAX_SIZE = 2;
public RemoverThread(AbstractCustomCache customCache) {
this.customCache = customCache;
}
@Override
public void run() {
if (customCache.getCacheEntry().size() > MAX_SIZE) {
List<String> gg = new ArrayList<>(customCache.getCacheEntry().keySet());
for (String s : gg) {
System.out.println("Element was remove: " + customCache.getCacheEntry().remove(s));
System.out.println("Time: " + new SimpleDateFormat("yyyy/MM/dd HH:mm:ss").format(Calendar.getInstance().getTime()));
if (customCache.getCacheEntry().size() <= MAX_SIZE) {
break;
}
}
}
}
}
My Main:
public class Main {
public static void main(String[] args) {
AbstractCustomCacheStatistics gh = new MapCacheStatistics();
AbstractCustomCache gg = new MapCache(gh);
for (int i = 0; i < 5; i++){
gg.put("ab" + i);
}
RemoverThread removerThread = new RemoverThread(gg);
Executors.newScheduledThreadPool(2).scheduleAtFixedRate(removerThread, 5, 5, TimeUnit.SECONDS);
for (int i = 0; i < 3; i++){
gg.put("abc" + i);
}
}
}
AbstractCustomCache:
public abstract class AbstractCustomCache implements CustomCache{
private Map<String, CacheEntry> cacheEntry = new LinkedHashMap<>();
public Map<String, CacheEntry> getCacheEntry() {
return Collections.synchronizedMap(cacheEntry);
}
}
У меня есть это в моем выводе:
Element was remove: CacheEntry{field='ab0'}
Time: 2019/01/31 11:39:11
Element was remove: CacheEntry{field='ab1'}
Time: 2019/01/31 11:39:11
Element was remove: CacheEntry{field='ab2'}
Time: 2019/01/31 11:39:11
Element was remove: CacheEntry{field='ab3'}
Time: 2019/01/31 11:39:11
Element was remove: CacheEntry{field='ab4'}
Time: 2019/01/31 11:39:11
Element was remove: CacheEntry{field='abc0'}
Time: 2019/01/31 11:39:11
Что я делаю не так?Как это можно улучшить?Я хочу, чтобы удаление с карты происходило каждые 5 секунд.Например, я добавил ab0, ab1, ab2, ab3, ab4
.Поток должен удалить ab0, ab1, ab2
.Так как элементы на карте больше MAX_SIZE
.Затем я добавляю abc0, abc1, abc2
.И через 5 секунд после удаления первых элементов ab3, ab4, abc0
следует удалить.Но, как вы можете видеть, все элементы удаляются одновременно.