7

我正在尝试了解 java 中的线程安全机制，我需要一些帮助。我有一堂课：

public class ThreadSafe {

    private Executor executor = new ScheduledThreadPoolExecutor(5);

    private long value = 0;

    public void method() {
        synchronized (this) {
            System.out.println(Thread.currentThread());
            this.value++;
        }
    }

    private synchronized long getValue() {
        return this.value;
    }

    public static void main(String... args) {
        ThreadSafe threadSafe = new ThreadSafe();
        for (int i = 0; i < 10; i++) {
            threadSafe.executor.execute(new MyThread());
        }

    }

    private static class MyThread extends Thread {

        private ThreadSafe threadSafe = new ThreadSafe();

        private AtomicBoolean shutdownInitialized = new AtomicBoolean(false);

        @Override
        public void run() {
            while (!shutdownInitialized.get()) {
                threadSafe.method();
                System.out.println(threadSafe.getValue());
            }
        }
    }

}

在这里，我试图使value线程安全，一次只能由一个线程访问。当我运行这个程序时，我看到有不止一个线程在运行，value即使我将它包装在synchronized块中。当然这个循环将是无限的，但它只是一个例子，我在几秒钟后手动停止这个程序，所以我有：

2470
Thread[pool-1-thread-3,5,main]
2470
Thread[pool-1-thread-5,5,main]
2470
Thread[pool-1-thread-2,5,main]

不同的线程正在访问和更改 this value。有人可以向我解释为什么会这样吗？以及如何使这个全局变量线程安全？

4

2 回答 2

10

每个线程都有自己的ThreadSafe，每个线程都有ThreadSafe自己的，不同的value。此外，synchronized方法 lock on this，因此每个方法都ThreadSafe在锁定自己——并且它们都没有在线程之间共享。这称为线程局部性，它是确保线程安全的最简单方法。:)

要进行我认为您想要的实验，您需要进行更改MyThread，使其构造函数接受一个ThreadSafe参数（而不是构造一个参数）。然后，让 main 方法创建一个并在构建时ThreadSafe将其分配给每个方法。MyThread

于 2013-05-03T14:37:02.300 回答
4

您每次都获得相同的值，因为您的每个Runnables 都有自己的ThreadSafe类实例。

如果您希望他们都共享同一个类，那么您将只需要一个实例ThreadSafe并将其传递给您的所有工作 - 见下文。如前所述，AtomicLong如果您想要一个线程安全的 shared ，那么 an 是要走的路long。

另外，你的MyThread班级不应该 extend Thread。它应该改为implements Runnable。您的代码正在运行，Thread因为implements Runnable. 如果你这样做myThread.interrupt()了，它实际上不会中断线程，因为它是调用你的run()方法的线程池线程。

像下面这样的东西会起作用：

ThreadSafe threadSafe = new ThreadSafe();
for (int i = 0; i < 10; i++) {
    threadSafe.executor.execute(new MyRunnable(threadSafe));
}
...
private static class MyRunnable implements Runnable {
    private final ThreadSafe threadSafe;
    public MyRunnable(ThreadSafe threadSafe) {
       this.threadSafe = threadSafe;
    }
    ...
于 2013-05-03T14:37:35.823 回答