Как сделать вызов функции отложенной неблокирующей функции

Question

Я хочу вызвать функцию HashSet add с некоторой задержкой, но без блокировки текущего потока. Есть простое решение, чтобы достичь что-то вроде этого:

Utils.sleep(1000, myHashSet.add(foo)); //added after 1 second 
//code here runs immediately without delay 
... 

Answer 1

Вы можете использовать ScheduledThreadPoolExecutor.schedule:

ScheduledThreadPoolExecutor exec = new ScheduledThreadPoolExecutor(1); 

exec.schedule(new Runnable() { 
      public void run() { 
       myHashSet.add(foo); 
      } 
    }, 1, TimeUnit.SECONDS); 

Он будет выполнять код после того, как 1 секунду в отдельном потоке. Однако будьте осторожны при одновременных модификациях myHashSet. Если вы одновременно изменяете коллекцию из другого потока или пытаетесь перебрать его, у вас могут быть проблемы, и вам нужно будет использовать блокировки.

Answer 2

Проверить ThreadPoolExecutor.schedule() метод.

Answer 3

Равнина раствор ванили будет:

new Thread(new Runnable() { 
     public void run() { 
      try { Thread.sleep(1000); } 
      catch (InterruptedException ie) {} 
      myHashSet.add(foo); 
     } 
    }).start(); 

Там намного меньше, что происходит за кулисами здесь, чем с ThreadPoolExecutor. TPE может быть удобнее контролировать количество потоков, но если вы отключаете много потоков, которые спят или ждут, ограничение их числа может повредить производительность намного больше, чем помогает.

И вы хотите синхронизировать на myHashSet, если вы еще не обработали это. Помните, что вам нужно синхронизировать везде, чтобы это не приносило пользы. Есть другие способы справиться с этим, например Collections.synchronizedMap или ConcurrentHashMap.