简单的 Java 回调不起作用

Question

interface CallableInterface
{
    void callBackMethod();
}

class Worker
{   
    public static ArrayList<String> names = new ArrayList<String>();
    static Timer t = new Timer();

    public void addToList(String newAdd, CallableInterface callback)
    {   
        names.add("BMW");
        names.add("DODGE");

        t.schedule(new TimerTask() {
            @Override
            public void run() {     
                names.add(newAdd);
            }
        }, 5000);

       callback.callBackMethod();
    }

    public void printList(){
        System.out.println(Worker.names);
    }
}


class Boss implements CallableInterface
{   
    Worker w1 = new Worker();

    public Boss(String carName)
    {   
        w1.addToList(carName, this);
    }
    public void callBackMethod()
    {
        w1.printList();
    }
}


public class IntroCallbacks
{ 
    public static void main(String[] args)
    {
        Boss b = new Boss("Mercedes");   
    }
}

我正在使用计时器模拟网络延迟。这个想法是等待计时器完成（在本例中为 5 秒），然后打印 arrayList。无论我对代码做什么，我总是只得到[BMW，DODGE]。

应该是 [BMW, DODGE, MERCEDES]。

我错过了什么？

Answer 1

Worker::addToList 在安排计时器后立即调用Boss::callBackMethod。这将打印列表，该列表当前只有 2 个元素。约 4.99 秒后，最后一个元素被添加到列表中，但它已经被打印出来了。

如果您只想在添加第三个元素后打印列表，请将回调的调用移至添加该元素后：

public void addToList(String newAdd, CallableInterface callback)
{   
    names.add("BMW");
    names.add("DODGE");

    t.schedule(new TimerTask() {
        @Override
        public void run() {     
            names.add(newAdd);
            callback.callBackMethod();
        }
    }, 5000);
}

或者使用一些同步机制，比如CountDownLatch

Answer 2

我会在添加名称后使用CompletableFuture 链接打印。您可以使用延迟的 Executor 而不是 Timer 来引入 5 秒的延迟。

import static java.util.concurrent.TimeUnit.SECONDS;

import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.Executor;

class Worker {
    private List<String> names = new ArrayList<String>();

    public CompletableFuture<Void> addToList(String name, Runnable callback) {
        names.add("BMW");
        names.add("DODGE");

        Executor in5seconds = CompletableFuture.delayedExecutor(5, SECONDS);

        return CompletableFuture.runAsync(() -> names.add(name), in5seconds)
            .thenRun(callback::run);
    }

    public void printList() {
        System.out.println(names);
    }
}

class Boss implements Runnable {
    private Worker worker = new Worker();
    private CompletableFuture<Void> future;

    public Boss(String carName) {
        future = worker.addToList(carName, this);
    }

    public void run() {
        worker.printList();
    }

    public CompletableFuture<Void> getFuture() {
        return future;
    }
}

public class IntroCallbacks {
    public static void main(String[] args) {
        Boss boss = new Boss("Mercedes");
        boss.getFuture().join();
    }
}

必须等到未来isDone()或join()结束，否则程序将结束，后台守护线程将在任何有趣的事情（包括输出）发生之前终止。

Answer 3

此代码将解决您的问题.. :)

    import java.util.ArrayList;
    import java.util.Timer;
    import java.util.TimerTask;

    interface CallableInterface
    {
        void callBackMethod();
    }

    class Worker
    {   
        public static ArrayList<String> names = new ArrayList<String>();
        static Timer t = new Timer();

        public void addToList(String newAdd, CallableInterface callback)
        {   
            names.add("BMW");
            names.add("DODGE");

            t.schedule(new TimerTask() {
                @Override
                public void run() {     
                    names.add(newAdd);
                    callback.callBackMethod();
                }
            }, 5000);


        }

        public void printList(){
            System.out.println(Worker.names);
        }
    }


    class Boss implements CallableInterface
    {   
        Worker w1 = new Worker();

        public Boss(String carName)
        {   
            w1.addToList(carName, this);
        }
        public void callBackMethod()
        {
            w1.printList();
        }
    }

    public class Main {

        public static void main(String[] args) {
            Boss b = new Boss("Mercedes");   

        }

    }