碼上歡樂
相關內容    簡體    繁體

對synchronized(this)的一些理解

本文轉載自   查看原文   2018-01-23 10:04   17584 

一、當兩個並發線程訪問同一個對象object中的這個synchronized(this)同步代碼塊時，一個時間內只能有一個線程得到執行。另一個線程必須等待當前線程執行完這個代碼塊以后才能執行該代碼塊。

二、然而，當一個線程訪問object的一個synchronized(this)同步代碼塊時，另一個線程仍然可以訪問該object中的非synchronized(this)同步代碼塊。

三、尤其關鍵的是，當一個線程訪問object的一個synchronized(this)同步代碼塊時，其他線程對object中所有其它synchronized(this)同步代碼塊的訪問將被阻塞。

四、第三個例子同樣適用其它同步代碼塊。也就是說，當一個線程訪問object的一個synchronized(this)同步代碼塊時，它就獲得了這個object的對象鎖。結果，其它線程對該object對象所有同步代碼部分的訪問都被暫時阻塞。

五、以上規則對其它對象鎖同樣適用.

舉例說明：

一、當兩個並發線程訪問同一個對象object中的這個synchronized(this)同步代碼塊時，一個時間內只能有一個線程得到執行。另一個線程必須等待當前線程執行完這個代碼塊以后才能執行該代碼塊。

 

[java] view plain copy print?
  1. package ths;  
  2.   
  3. public class Thread1 implements Runnable {  
  4.     public void run() {  
  5.         synchronized (this) {  
  6.             for (int i = 0; i < 5; i++) {  
  7.                 System.out.println(Thread.currentThread().getName()  
  8.                         + " synchronized loop " + i);  
  9.             }  
  10.         }  
  11.     }  
  12.   
  13.     public static void main(String[] args) {  
  14.         Thread1 t1 = new Thread1();  
  15.         Thread ta = new Thread(t1, "A");  
  16.         Thread tb = new Thread(t1, "B");  
  17.         ta.start();  
  18.         tb.start();  
  19.     }  
  20. }  
package ths;

public class Thread1 implements Runnable {
	public void run() {
		synchronized (this) {
			for (int i = 0; i < 5; i++) {
				System.out.println(Thread.currentThread().getName()
						+ " synchronized loop " + i);
			}
		}
	}

	public static void main(String[] args) {
		Thread1 t1 = new Thread1();
		Thread ta = new Thread(t1, "A");
		Thread tb = new Thread(t1, "B");
		ta.start();
		tb.start();
	}
}

 

結果：
A synchronized loop 0
A synchronized loop 1
A synchronized loop 2
A synchronized loop 3
A synchronized loop 4
B synchronized loop 0
B synchronized loop 1
B synchronized loop 2
B synchronized loop 3
B synchronized loop 4

二、然而，當一個線程訪問object的一個synchronized(this)同步代碼塊時，另一個線程仍然可以訪問該object中的非synchronized(this)同步代碼塊。

 

[java] view plain copy print?
  1. package ths;  
  2.   
  3. public class Thread2 {  
  4.     public void m4t1() {  
  5.         synchronized (this) {  
  6.             int i = 5;  
  7.             while (i-- > 0) {  
  8.                 System.out  
  9.                         .println(Thread.currentThread().getName() + " : " + i);  
  10.                 try {  
  11.                     Thread.sleep(500);  
  12.                 } catch (InterruptedException ie) {  
  13.                 }  
  14.             }  
  15.         }  
  16.     }  
  17.   
  18.     public void m4t2() {  
  19.         int i = 5;  
  20.         while (i-- > 0) {  
  21.             System.out.println(Thread.currentThread().getName() + " : " + i);  
  22.             try {  
  23.                 Thread.sleep(500);  
  24.             } catch (InterruptedException ie) {  
  25.             }  
  26.         }  
  27.     }  
  28.   
  29.     public static void main(String[] args) {  
  30.         final Thread2 myt2 = new Thread2();  
  31.         Thread t1 = new Thread(new Runnable() {  
  32.             public void run() {  
  33.                 myt2.m4t1();  
  34.             }  
  35.         }, "t1");  
  36.         Thread t2 = new Thread(new Runnable() {  
  37.             public void run() {  
  38.                 myt2.m4t2();  
  39.             }  
  40.         }, "t2");  
  41.         t1.start();  
  42.         t2.start();  
  43.     }  
  44. }  
package ths;

public class Thread2 {
	public void m4t1() {
		synchronized (this) {
			int i = 5;
			while (i-- > 0) {
				System.out
						.println(Thread.currentThread().getName() + " : " + i);
				try {
					Thread.sleep(500);
				} catch (InterruptedException ie) {
				}
			}
		}
	}

	public void m4t2() {
		int i = 5;
		while (i-- > 0) {
			System.out.println(Thread.currentThread().getName() + " : " + i);
			try {
				Thread.sleep(500);
			} catch (InterruptedException ie) {
			}
		}
	}

	public static void main(String[] args) {
		final Thread2 myt2 = new Thread2();
		Thread t1 = new Thread(new Runnable() {
			public void run() {
				myt2.m4t1();
			}
		}, "t1");
		Thread t2 = new Thread(new Runnable() {
			public void run() {
				myt2.m4t2();
			}
		}, "t2");
		t1.start();
		t2.start();
	}
}

 

結果：
t1 : 4
t2 : 4
t1 : 3
t2 : 3
t1 : 2
t2 : 2
t1 : 1
t2 : 1
t1 : 0
t2 : 0

三、尤其關鍵的是，當一個線程訪問object的一個synchronized(this)同步代碼塊時，其他線程對object中所有其它synchronized(this)同步代碼塊的訪問將被阻塞。

 

//修改Thread2.m4t2()方法：

[java] view plain copy print?
  1. public void m4t2() {  
  2.     synchronized (this) {  
  3.         int i = 5;  
  4.         while (i-- > 0) {  
  5.             System.out  
  6.                     .println(Thread.currentThread().getName() + " : " + i);  
  7.             try {  
  8.                 Thread.sleep(500);  
  9.             } catch (InterruptedException ie) {  
  10.             }  
  11.         }  
  12.     }  
  13.   
  14. }  
	public void m4t2() {
		synchronized (this) {
			int i = 5;
			while (i-- > 0) {
				System.out
						.println(Thread.currentThread().getName() + " : " + i);
				try {
					Thread.sleep(500);
				} catch (InterruptedException ie) {
				}
			}
		}

	}


結果：
t1 : 4
t1 : 3
t1 : 2
t1 : 1
t1 : 0
t2 : 4
t2 : 3
t2 : 2
t2 : 1
t2 : 0

四、第三個例子同樣適用其它同步代碼塊。也就是說，當一個線程訪問object的一個synchronized(this)同步代碼塊時，它就獲得了這個object的對象鎖。結果，其它線程對該object對象所有同步代碼部分的訪問都被暫時阻塞。

//修改Thread2.m4t2()方法如下：

[java] view plain copy print?
  1. public synchronized void m4t2() {  
  2.     int i = 5;  
  3.     while (i-- > 0) {  
  4.         System.out.println(Thread.currentThread().getName() + " : " + i);  
  5.         try {  
  6.             Thread.sleep(500);  
  7.         } catch (InterruptedException ie) {  
  8.         }  
  9.     }  
  10. }  
	public synchronized void m4t2() {
		int i = 5;
		while (i-- > 0) {
			System.out.println(Thread.currentThread().getName() + " : " + i);
			try {
				Thread.sleep(500);
			} catch (InterruptedException ie) {
			}
		}
	}


結果：
t1 : 4
t1 : 3
t1 : 2
t1 : 1
t1 : 0
t2 : 4
t2 : 3
t2 : 2
t2 : 1
t2 : 0

五、以上規則對其它對象鎖同樣適用:

[java] view plain copy print?
  1. package ths;  
  2.   
  3. public class Thread3 {  
  4.     class Inner {  
  5.         private void m4t1() {  
  6.             int i = 5;  
  7.             while (i-- > 0) {  
  8.                 System.out.println(Thread.currentThread().getName()  
  9.                         + " : Inner.m4t1()=" + i);  
  10.                 try {  
  11.                     Thread.sleep(500);  
  12.                 } catch (InterruptedException ie) {  
  13.                 }  
  14.             }  
  15.         }  
  16.   
  17.         private void m4t2() {  
  18.             int i = 5;  
  19.             while (i-- > 0) {  
  20.                 System.out.println(Thread.currentThread().getName()  
  21.                         + " : Inner.m4t2()=" + i);  
  22.                 try {  
  23.                     Thread.sleep(500);  
  24.                 } catch (InterruptedException ie) {  
  25.                 }  
  26.             }  
  27.         }  
  28.     }  
  29.   
  30.     private void m4t1(Inner inner) {  
  31.         synchronized (inner) { // 使用對象鎖  
  32.             inner.m4t1();  
  33.         }  
  34.     }  
  35.   
  36.     private void m4t2(Inner inner) {  
  37.         inner.m4t2();  
  38.     }  
  39.   
  40.     public static void main(String[] args) {  
  41.         final Thread3 myt3 = new Thread3();  
  42.         final Inner inner = myt3.new Inner();  
  43.         Thread t1 = new Thread(new Runnable() {  
  44.             public void run() {  
  45.                 myt3.m4t1(inner);  
  46.             }  
  47.         }, "t1");  
  48.         Thread t2 = new Thread(new Runnable() {  
  49.             public void run() {  
  50.                 myt3.m4t2(inner);  
  51.             }  
  52.         }, "t2");  
  53.         t1.start();  
  54.         t2.start();  
  55.     }  
  56. }  
package ths;

public class Thread3 {
	class Inner {
		private void m4t1() {
			int i = 5;
			while (i-- > 0) {
				System.out.println(Thread.currentThread().getName()
						+ " : Inner.m4t1()=" + i);
				try {
					Thread.sleep(500);
				} catch (InterruptedException ie) {
				}
			}
		}

		private void m4t2() {
			int i = 5;
			while (i-- > 0) {
				System.out.println(Thread.currentThread().getName()
						+ " : Inner.m4t2()=" + i);
				try {
					Thread.sleep(500);
				} catch (InterruptedException ie) {
				}
			}
		}
	}

	private void m4t1(Inner inner) {
		synchronized (inner) { // 使用對象鎖
			inner.m4t1();
		}
	}

	private void m4t2(Inner inner) {
		inner.m4t2();
	}

	public static void main(String[] args) {
		final Thread3 myt3 = new Thread3();
		final Inner inner = myt3.new Inner();
		Thread t1 = new Thread(new Runnable() {
			public void run() {
				myt3.m4t1(inner);
			}
		}, "t1");
		Thread t2 = new Thread(new Runnable() {
			public void run() {
				myt3.m4t2(inner);
			}
		}, "t2");
		t1.start();
		t2.start();
	}
}


結果：

盡管線程t1獲得了對Inner的對象鎖，但由於線程t2訪問的是同一個Inner中的非同步部分。所以兩個線程互不干擾。
t1 : Inner.m4t1()=4
t2 : Inner.m4t2()=4
t1 : Inner.m4t1()=3
t2 : Inner.m4t2()=3
t1 : Inner.m4t1()=2
t2 : Inner.m4t2()=2
t1 : Inner.m4t1()=1
t2 : Inner.m4t2()=1
t1 : Inner.m4t1()=0
t2 : Inner.m4t2()=0

現在在Inner.m4t2()前面加上synchronized：

[java] view plain copy print?
  1. private synchronized void m4t2() {  
  2.     int i = 5;  
  3.     while (i-- > 0) {  
  4.         System.out.println(Thread.currentThread().getName()  
  5.                 + " : Inner.m4t2()=" + i);  
  6.         try {  
  7.             Thread.sleep(500);  
  8.         } catch (InterruptedException ie) {  
  9.         }  
  10.     }  
  11. }  
	private synchronized void m4t2() {
		int i = 5;
		while (i-- > 0) {
			System.out.println(Thread.currentThread().getName()
					+ " : Inner.m4t2()=" + i);
			try {
				Thread.sleep(500);
			} catch (InterruptedException ie) {
			}
		}
	}


結果：

盡管線程t1與t2訪問了同一個Inner對象中兩個毫不相關的部分,但因為t1先獲得了對Inner的對象鎖，所以t2對Inner.m4t2()的訪問也被阻塞，因為m4t2()是Inner中的一個同步方


免責聲明！

本站轉載的文章為個人學習借鑒使用，本站對版權不負任何法律責任。如果侵犯了您的隱私權益，請聯系本站郵箱yoyou2525@163.com刪除。



猜您在找 JavaWeb的一些理解 關於gevent的一些理解(一) CIM的一些理解 對redis的一些理解 對ThreadLocal的一些理解 關於零拷貝的一些理解 關於溝通的一些理解 對sequence的一些理解 Hive的一些理解 關於gevent的一些理解(二)
 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM