值在 Runnable 类中被覆盖 - Java

Question

我遇到了 Runnable 类的问题。当相同的值传递给另一个类时，传递给可运行类的值将被它收到的最后一个值覆盖。 可运行类的功能是将值传递给另一个类中的另一个函数以打印它们。但只打印 Runnable 类收到的最后一个值。

这是我的代码， 这是传递值的主类。

public class MainClass {
    private int intVal = -1;
    public void MainMethod() {
        ExecutorUtil theExecutor = ExecutorUtil.GetInstance();
        for(int i = 0; i < 3; i++) {
            intVal = i;
            synchronized (this) {
                theExecutor.SubmitTask(new ActionExecutor(intVal));
            }
        }
    }
}

这是我用来调用线程的 executorUtil。

import java.util.concurrent.ExecutorService;
import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.BlockingQueue;

public class ExecutorUtil {
    private static ExecutorUtil theInstance;
    private ExecutorService theExecutor;
    private BlockingQueue<Runnable> theQueue;



    protected ExecutorUtil() {
        theExecutor = CreateThreadPoolExecutor();
    }

    private ExecutorService CreateThreadPoolExecutor() {
        theQueue = new LinkedBlockingQueue<Runnable>();
        ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(10, 10, 900, java.util.concurrent.TimeUnit.SECONDS, theQueue);
        threadPoolExecutor.allowCoreThreadTimeOut(true);
        return threadPoolExecutor;
    }

    public static ExecutorUtil GetInstance() {
        if (theInstance == null) {
            synchronized(ExecutorUtil.class) {
                if (theInstance == null) {
                    theInstance = new ExecutorUtil();
                }
            }
        }
        return theInstance;
    }

    public void SubmitTask(Runnable runnable) {
        theExecutor.submit(runnable);
    }
}

这是将接收到的值传递给打印这些值的函数的线程。

public class ActionExecutor implements Runnable {
    int iVal = -1;
    public ActionExecutor(int iVal) {
        this.iVal = iVal;
    }
    public void run() {
        SecondClass sc = new SecondClass();
        sc.printIntVal(iVal);
    }
}

这是打印值的类。

public class SecondClass {
    public void printIntVal(int i) {
        System.out.println(i);
    }
}

预期输出：

0
1
2

获得的输出：

2
2
2

不知道为什么会这样！

更新：

仅当使用非原始数据类型时才会出现此问题。在我的示例中，我使用了一个整数值 (intVal)。由于 java 传递原始数据类型的值，因此按预期获得了输出。但在我的原始代码中，我使用了 JSONObject。并且由于 java 为非原始数据类型传递对象的引用，因此该值被覆盖。

我通过为每次迭代创建新的 JSONObject 解决了这个问题。

Answer 1

似乎在某处您有 static 字段，用于存储您的号码。 所以，我想，你有 3 个 ActionExecutor 实例，但看起来 field 有 static 修饰符，所以每个实例都有最新的值。

检查这个案例...

Answer 2

所以在我阅读了您的问题并研究了您的代码之后，我不妨尝试一下。你瞧，它按预期工作。这里唯一的区别是存在竞争条件，因此输出顺序不同，但不会打印相同的数字。 输出可能

• 第一：0 1 2
• 第二：0 1 2
• 第三：2 1 0

这里是完整的代码来试一试：

import java.util.concurrent.BlockingQueue;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.ThreadPoolExecutor;

public class MainClass {

     private int intVal = -1;
        public void MainMethod() {
            ExecutorUtil theExecutor = ExecutorUtil.GetInstance();
            for(int i = 0; i < 3; i++) {
                intVal = i;
                synchronized (this) {
                    theExecutor.SubmitTask(new ActionExecutor(intVal));
                }
            }
        }

        public class ActionExecutor implements Runnable {
            int iVal = -1;
            public ActionExecutor(int iVal) {
                this.iVal = iVal;
            }
            public void run() {
                SecondClass sc = new SecondClass();
                sc.printIntVal(iVal);
            }
        }
        public class SecondClass {
            public void printIntVal(int i) {
                System.out.println(i);
            }
        }

        public static class ExecutorUtil {
          private static ExecutorUtil theInstance;
            private ExecutorService theExecutor;
            private BlockingQueue<Runnable> theQueue;



            protected ExecutorUtil() {
                theExecutor = CreateThreadPoolExecutor();
            }

            private ExecutorService CreateThreadPoolExecutor() {
                theQueue = new LinkedBlockingQueue<Runnable>();
                ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(10, 10, 900, java.util.concurrent.TimeUnit.SECONDS, theQueue);
                threadPoolExecutor.allowCoreThreadTimeOut(true);
                return threadPoolExecutor;
            }

            public static ExecutorUtil GetInstance() {
                if (theInstance == null) {
                    synchronized(ExecutorUtil.class) {
                        if (theInstance == null) {
                            theInstance = new ExecutorUtil();
                        }
                    }
                }
                return theInstance;
            }

            public void SubmitTask(Runnable runnable) {
                theExecutor.submit(runnable);
            }
        }

        public static void main(String[] args) {
            MainClass main = new MainClass();
            main.MainMethod();
        }
}

您可能想要清理并重建您的项目。否则它正在工作..