解决“变量可能尚未初始化”错误

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，但我不想因为它用于其他东西。

它在 cmets 中说，但这是错误：

%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：

// this class handles atomic updates and memory synchronization
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 (true) {
                    ScheduledFuture future = futureReference.get();
                    if (future != null) {
                        future.cancel(true);
                        break;
                    }
                    try {
                        Thread.sleep(1);
                    } catch (InterruptedException e) {
                        Thread.currentThread.().interrupt();
                    }
                }
            }
        }
    },
    0, delay, TimeUnit.MILLISECONDS);
// this sets the future reference so the thread can use it
futureReference.set(exec);

Answer 2

我知道基本上有两种方法可以解决这个问题。不幸的是，它们都不是特别好的代码质量，所以我不确定我是否可以推荐它们。

第一个解决方案是使 exec 成为最终的单元素数组。然后，即使数组本身是最终的，您也可以在声明后分配 exec[0] = something。一种变体是使用/创建一些引用类（因为您可以更改最终引用的属性，但不能更改引用本身）。以下是一个简单的示例，但请记住，它没有考虑任何并发问题（请参阅下文）：

    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 移出方法的本地范围并使其成为类属性。

但是我必须警告你，特别是在初始延迟为零的情况下，runnable 中的代码很有可能在 scheduleAtFixedRate 方法返回之前执行，在这种情况下 exec[0] 仍然为空。此外，您应该使用同步来确保主线程设置的 exec[0] 的值可用于负责执行可运行对象的线程。

上述两种解决方案都应该有效，但我认为它们中的任何一种都不是特别好。

Answer 3

既然知道执行次数，为什么还要使用固定速率调度程序， 我认为简单的 for 循环就可以完成这项工作

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

正如 WalterM 所说：创建许多新实例不是好方法，请在循环中使用引用。