Ошибка «инициализации переменной»

Question

public final void sendAdvertisement(final Advertisement advertisment, int delay, final int repetitions){ 
    final ScheduledFuture exec = executor.scheduleAtFixedRate(//<< initialized on this line 
     new Runnable(){ 
      int totalSends = 0; 
      public void run(){ 
       //do stuff here 

       if(++totalSends >= repetitions) exec.cancel(true); //<< here is says exec might not be initialized 
      } 
     }, 
    0, delay, TimeUnit.MILLISECONDS); 
} 

Если это невозможно, можете ли вы предложить лучший способ сделать это? Я не смог найти метод для этого в ScheduledThreadPoolExecutor. в основном то, что я пытаюсь сделать, это запустить этот код 3 раза, а затем отменить «таймер». Вероятно, я мог бы использовать Swing Timer, но я не хочу, так как он используется для других вещей.

Это говорит в комментариях, но это ошибка:

%PATH%Discovery.java:148: variable exec might not have been initialized 
       if(++totalSends >= repetitions) exec.cancel(true); 

Answer 1

Ваш код может работать с точки зрения удаления предупреждения компилятора, но вся точка предупреждения указывает, что вы можете получить доступ к переменной, которая еще не назначена. Даже если exec или exec[0] не является нулевым, также нет гарантии, что объект ScheduledFuture был даже правильно инициализирован - да, хотя внутренний поток может работать. Это очень опасно и может работать некоторое время, но затем резко сокращаться при производстве, когда вы переходите к архитектуре с большим количеством ядер или при разных условиях нагрузки. Он также может работать, но затем вы меняете свой код do stuff here через месяц, и он начинает терпеть неудачу.

Я вижу несколько способов, которыми вы можете добиться этого лучше. Они сложнее, но более безопасны и совместимы с Java. Первое, что приходит на ум, - это использовать AtomicReference:

final AtomicReference<ScheduledFuture> futureReference = 
    new AtomicReference<ScheduledFuture>(); 
ScheduledFuture exec = executor.scheduleAtFixedRate(
    new Runnable() { 
     int totalSends = 0; 
     public void run() { 
      //do stuff here 
      if (++totalSends >= repetitions) { 
       // we need to wait for the future to be initialized 
       while (futureReference.get() == null) { 
        try { 
         Thread.sleep(1); 
        } catch (InterruptedException e) { 
         Thread.currentThread.().interrupt(); 
        } 
       } 
       futureReference.get().cancel(true); 
      } 
     } 
    }, 
    0, delay, TimeUnit.MILLISECONDS); 
futureReference.set(exec); 

Answer 2

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

Первым решением было бы сделать exec окончательным одноэлементным массивом. Затем вы можете назначить exec [0] = что-то после объявления, даже если сам массив является окончательным. Вариант этого состоит в том, чтобы использовать/создать некоторый ссылочный класс (поскольку вы можете изменять атрибуты конечных ссылок, но не сами ссылки). Ниже приведен простой пример, но имейте в виду, что он не принимает каких-либо проблем параллелизма во внимание (см дальше):

final ScheduledFuture[] exec = new ScheduledFixture[1]; 
    exec[0] = executor.scheduleAtFixedRate(//<< initialized on this line 
      new Runnable(){ 
       int totalSends = 0; 
       public void run(){ 
        //do stuff here 

        if(++totalSends >= repetitions) exec[0].cancel(true); //<< here is says exec might not be initialized 
       } 
      }, 
     0, delay, TimeUnit.MILLISECONDS); 

В качестве альтернативы вы можете переместить Exec из локальной области видимости метода и сделать его вместо этого атрибут класса.

Я должен предупредить вас, что, особенно с начальной задержкой нуля, существует реальная возможность выполнения кода внутри исполняемого файла до того, как возвращается метод scheduleAtFixedRate, и в этом случае exec [0] будет по-прежнему иметь значение null. Кроме того, вы должны использовать синхронизацию, чтобы гарантировать, что значение exec [0], заданное основным потоком, будет доступно потоку, ответственному за выполнение runnable.

Оба эти решения должны работать, но я не думаю, что любой из них особенно хорош.

Answer 3

почему вы используете scheduer с фиксированной ставкой, когда вы знаете, число казней, я думаю, что простой цикл сделает работу

for (int i = 0; i < iterations; i++) { 
    executor.schedule(new Runnable() { 
     public void run() { 
      // do stuff here 
     } 
    }, delay * i, TimeUnit.MILLISECONDS); 
} 

Как WalterM сказал: Это не хороший способ создать много новых экземпляров, используйте ссылку в цикле.