1

所以在这里我写了三个简单的类来检查多个线程在java中是如何工作的，但是每次我运行它时它们都会产生不同的结果。这是代码：

        public class Accum {

        private static Accum a = new Accum();
        private int counter = 0;

        private Accum(){}

        public static Accum getAccum(){
            return a;
        }

        public void updateCounter(int add){
            counter+=add;
        }

        public int getCount(){
            return counter;
        }
    }//end of class

        public class ThreadOne implements Runnable {
        Accum a = Accum.getAccum();
        public void run() {
            for(int x=0; x<98; x++){
                //System.out.println("Counter in TWO "+a.getCount());
                a.updateCounter(1000);
                try{
                    Thread.sleep(50);
                }catch(InterruptedException ex){}
            }
            System.out.println("one " + a.getCount());
        }
    }//end of class

        public class ThreadTwo implements Runnable{
        Accum a = Accum.getAccum();
        public void run() {
            for(int x=0; x<99; x++){
                //System.out.println("counter in Two "+a.getCount());
                a.updateCounter(1);
                try{
                    Thread.sleep(50);
                }catch(InterruptedException ex){}
            }
            System.out.println("two "+a.getCount());
    }

        public class TestThreaad {
        public static void main(String[]args){
            ThreadOne t1 = new ThreadOne();
            ThreadTwo t2 = new ThreadTwo();

            Thread one = new Thread(t1);
            Thread two = new Thread(t2);

            one.start();
            two.start();
        }
    }end of class

所以预期的结果是：一个98098，两个98099，但结果结果只是不可预知，有时是78000或81000，我不知道..

但是如果我添加一些代码来打印一行当前计数值，最终结果将是正确的..

实在不知道怎么回事，竟然在ThreadOne和ThreadTwo，run()方法中加上了关键字synchronized，问题依旧……

我已经研究了 Java 3 个月，这是我遇到过的最难以捉摸的问题......所以提前感谢任何人可以帮助我理解多线程的基本点......

4

3 回答 3

2

代码不同步。由于它是不同步的，不同的Thread尝试更新计数器可能会同时导致此问题。

如果您进行了同步updateCounter，则此方法的访问权限将是正确的。

public synchronized void updateCounter(int add){
      counter+=add;
}
于 2013-09-02T11:26:13.623 回答
1

在您的示例中，Accum实例在线程之间共享。您的更新过程是一个典型的 READ、COMPUTE-UPDATE、WRITE 操作序列。因为资源是共享的且不受保护，所以这三个操作（来自两个线程——进行六个操作）可以以多种不同的方式交错，导致更新丢失。

这是操作的示例顺序（数字表示线程）：

READ #1           -> reads 10
COMPUTE-UPDATE #1 -> computes 1010
READ #2           -> reads 10
WRITE #1          -> writes 1010
COMPUTE-UPDATE #2 -> computes 11
WRITE #2          -> writes 11 (earlier update is lost)

所以你看，几乎任何结果都是可能的。正如@SubhrajyotiMajumder 所说，您可以使用synchronized它来修复它。但如果你这样做，也许线程不适合你的问题；或者，您需要另一个算法过程。

于 2013-09-02T11:35:24.617 回答
0

您的代码未正确同步。作为同步方法的替代方法，我建议使用AtomicInteger它来存储从不同线程访问和修改的变量。

于 2013-09-02T11:37:53.620 回答