线程何时共享对象？ - Java

Question

嘿，我试图把线程作为一个概念。 让我画你一个场景

class A { 
    private int counter = 0; 

    public void add() { 
     counter++; 
    } 

    public int getCounter() { 
     return counter; 
    } 
} 

class B implements Runnable { 
    public void run() { 
     A a = new A(); 
     a.add(); 
     a.add(); 
    } 
} 

class C implements Runnable { 
    public void run() { 
     A a = new A(); 
     System.out.println(a.getCounter()); 
    } 
} 

什么是System.out.println给我，当我运行C？ 我猜它给了我0，因为他们每个都创建了一个A的实例。

如果这是真的，你将如何分享线程之间的对象？

Answer 1

你不会在System.out上看到任何东西，因为你没有一个完整的程序。但是，假设你创建了两个线程，并且运行了B，然后运行C与另一个，是的，0会被打印出来，因为在你猜测的时候，每个线程都使用一个单独的A实例。这很好，因为A不会，没有任何内存障碍可以让它被多线程安全地访问。

要共享数据，您需要将一个对象传递给两个线程。例如：

final class Test { 

    public static void main(String[] argv) throws InterruptedException { 
    AtomicInteger shared = new AtomicInteger(); 
    Thread a = new B(shared).start(); 
    a.join(); 
    Thread b = new C(shared).start(); 
    b.join(); 
    } 

} 

final class B extends Thread { 

    private final AtomicInteger shared; 

    B(AtomicInteger shared) { this.shared = shared; } 

    @Override() 
    public void run() { 
    shared.getAndIncrement(); 
    shared.getAndIncrement(); 
    } 

} 

final class C extends Thread { 

    private final AtomicInteger shared; 

    C(AtomicInteger shared) { this.shared = shared; } 

    @Override() 
    public void run() { 
    System.out.println(shared.get()); 
    } 

} 

这将打印2，因为主要方法是确保线程顺序运行。在更现实的方法中，线程将同时启动，并且根据相对时序打印0,1或2。

Answer 2

在控制台中看到的东西（假设某些实例化C并将它传递给执行它的线程）将为0，因为没有其他任何内容正在写入该实例A.a是run方法的局部变量，没有别的东西可以看到它。

多线程访问是指对象在线程之间传递时。一个典型的例子是一个队列，其中有不同的线程写入数据结构，其他线程从相同的数据结构中删除对象。 写入队列（生产者）的每个线程都会创建对象并将其放入队列中。相同的对象将被不同的线程（称为消费者）检索，这些线程致力于从队列中取出对象并对它们执行某些操作。所以一个生产者创建的对象被放置在队列中，并保持在那里，直到被消费者占用。

这是一个简单的队列实现。它使用​​锁定内部列表，以便一次只有一个线程可以访问队列。

public class MyQueue<T> { 

    private List<T> list = new ArrayList<T>(); 

    public T take() throws InterruptedException { 
     synchronized(list) { 
      while (list.size() == 0) { 
       list.wait(); 
      } 
      return list.remove(0); 
     } 
    } 

    public void put(T object) { 
     synchronized(list) { 
      list.add(object); 
      list.notifyAll(); 
     } 
    } 
}