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);

解决方法:

从删除编译器警告的角度来看,您的代码可能会起作用,但是警告的整个重点是指出您可能正在访问尚未分配的变量.即使exec或exec [0]为非null,也无法保证ScheduledFuture对象甚至已经正确初始化-是的,即使内部线程可能正在运行.这是非常危险的,可能会工作一段时间,但是当您转移到具有更多核心的体系结构或在不同的负载环境下生产时会严重失败.它也可能起作用,但是从现在起一个月后,您就可以在此处更改您的工作代码,并且它开始失败.

我看到了几种可以更好地完成此任务的方法.它们更复杂,但也更安全,并且与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);