Я хочу вызвать функцию add HashSet с некоторой задержкой, но без блокировки текущего потока. Есть ли простое решение для достижения чего-то вроде этого:
Utils.sleep(1000, myHashSet.add(foo)); //added after 1 second
//code here runs immediately without delay
...
Вы можете использовать ScheduledThreadPoolExecutor.schedule:
ScheduledThreadPoolExecutor exec = new ScheduledThreadPoolExecutor(1);
exec.schedule(new Runnable() {
public void run() {
myHashSet.add(foo);
}
}, 1, TimeUnit.SECONDS);
Он выполнит ваш код через 1 секунду в отдельном потоке. Однако будьте осторожны с параллельными модификациями myHashSet. Если вы одновременно изменяете коллекцию из другого потока или пытаетесь перебрать ее, у вас могут возникнуть проблемы, и вам придется использовать блокировки.
Простое ванильное решение будет:
new Thread( new Runnable() {
public void run() {
try { Thread.sleep( 1000 ); }
catch (InterruptedException ie) {}
myHashSet.add( foo );
}
} ).start();
За кулисами здесь происходит намного меньше, чем с ThreadPoolExecutor. TPE может быть удобен для контроля количества потоков, но если вы запускаете много потоков, которые спят или ждут, ограничение их количества может снизить производительность гораздо больше, чем помочь.
И вы хотите синхронизироваться на myHashSet, если вы еще этого не сделали. Помните, что вам нужно синхронизировать везде, чтобы это принесло пользу. Есть и другие способы справиться с этим, например Collections.synchronizedMap или ConcurrentHashMap.
