Блог

 public class SyncBlockIssue {    public static void main(String[] args) {   Thread r1= new Multi();  Thread t1= new Thread(r1);   Thread t2= new Thread(r1);  t1.start();  t2.start();  }  }   class Multi extends Thread  {  Integer count =new Integer(0);   @Override  public void run() {  for(int i=0;ilt;100000;i  )  {   synchronized (count) {   //synchronized (this) { //working fine with this  count  ;  }   }  System.out.println(Thread.currentThread().getName()   " " count);   }   }  

Приведенный выше код печатает 2 миллиона из 2-го потока, независимо от того, сколько раз я запускаю, когда получаю блокировку на «этом», но где при печати произвольно учитывается, когда приобретается объект блокировки «подсчета». не мог бы кто-нибудь объяснить разницу.

Вот мое предположение, так как я не могу использовать комментарии для ввода такого количества слов.

Integer объекты неизменяемы:

 /**  * The value of the {@code Integer}.  *  * @serial  */  private final int value;   /**  * Constructs a newly allocated {@code Integer} object that  * represents the specified {@code int} value.  *  * @param value the value to be represented by the  * {@code Integer} object.  */  public Integer(int value) {  this.value = value;  }  

Итак, когда вы это сделаете count , Integer будет создан новый объект. Затем count ссылка направляется на новый объект.

Предположим, что следующий поток:

1. Thread r1 приобретает count блокировку (обратите внимание, что count object блокируется), в этот момент thread r2 блокируется.
2. r1 вызывает count , создается новый Integer объект. Затем count ссылка направляется на новый объект. И r1 отпустите замок.(Эта блокировка относится к предыдущему целочисленному объекту).
3. r2 который был заблокирован и заблокирован.
4. r1 также получает блокировку, потому count что уже указал на новый объект.
5. Оба потока выполняются count : возникает проблема.

Следующий код доказывает, что оба потока удерживают «блокировку» одновременно

 for(int i=0; ilt;2; i  )  {  synchronized (count) {  System.out.println(Thread.currentThread().getName()   "get lock");  count  ;  if (i == 1) {  try {  Thread.sleep(100000);  } catch (InterruptedException e) {  e.printStackTrace();  }  }  System.out.println(Thread.currentThread().getName()   "release lock");  }  }