Java多線程之synchronized

這裡通過三個測試類闡述了synchronized應用的不同場景

首先是最基本的synchronized Method的使用

1. package com.jadyer.thread.sync;
3. /**
4. * Synchronized Method Test
5. * @see ===================================================================================================
6. * @see 概述：Java中的每個對象都有一個鎖(lock)或者叫做監視器(monitor)
7. * @see 說明：當synchronized關鍵字修飾一個方法時，則該方法為同步方法
8. * @see 當某個線程訪問某個對象的synchronized方法時，則表示將該對象上鎖
9. * @see 此時其它的任何線程，均無法訪問該對象中的任何一個synchronized方法(但允許訪問該對象中的非synchronized方法)
10. * @see 直到該線程所訪問的synchronized方法執行完畢(或者拋出了異常)之後，該對象的鎖才會被釋放
11. * @see 此時其它的任何線程，才被允許訪問該synchronized方法，或者是該對象中的其它synchronized方法
12. * @see ===================================================================================================
13. * @see 總結：如果一個對象有多個synchronized方法，某一時刻某個線程已經執行了該對象中的某一個synchronized方法
14. * @see 那麼在該方法沒有執行完畢之前，其它線程是無法訪問該對象中的，包括該方法在內的，任何一個synchronized方法
15. * @see 重點在於判斷Synchronized鎖的是誰。如果該方法是靜態的，則鎖Class對象，否則鎖的就是當前對象
16. * @see ===================================================================================================
17. * @see 補充：1)這只是針對多個線程操作同一個類的同一個對象的情況。www.linuxidc.com若多個線程操作同一個類的不同對象，則不存在這種情況
18. * @see 2)Java中的volatile變量也可以看作是一種"程度較輕的synchronized"
19. * @see 關於volatile的更多信息，請參考http://www.ibm.com/developerworks/cn/java/j-jtp06197.html
20. * @see 備注：實際項目中，用到的更多的還是JDK5.0開始推出的Java並發包，即java.util.concurrent包裡面的工具類
21. * @see java.util.concurrent可以非常細粒度的實現並發。比如線程訪問到了一個已被鎖的對象，它可以讓這個線程等到10秒
22. * @see 10秒後如果該對象仍未被解鎖，那麼就可以返回給用戶超時的提示等，而如果使用synchronized則是無法這麼精確控制的
23. * @see ===================================================================================================
24. * @see 注意：1)當synchronized方法執行完或者發生異常時，會自動釋放鎖
25. * @see 2)被synchronized保護的數據應該是private的，否則也就沒必要去通過方法來訪問這個public的數據了
26. * @see ===================================================================================================
27. * @author 宏宇
28. * @create Feb 21, 2012 5:29:39 PM
29. */
30. public class SynchronizedTest {
31. public static void main(String[] args) {
32. Bank bank = new Bank();
34. Thread tt11 = new Thread(new ThreadRMB(bank));
36. //new一個新的Bank對象。此時存在兩個Bank對象，並且它們屬於同一個類的不同的對象
37. //如要驗證多個線程操作同一個類的不同的對象的synchronized方法，只需取消注釋該行代碼即可
38. //bank = new Bank();
40. Thread tt22 = new Thread(new ThreadDollar(bank));
42. tt11.start();
43. tt22.start();
44. }
45. }
48. class ThreadRMB implements Runnable{
49. private Bank bank;
50. public ThreadRMB(Bank bank){
51. this.bank = bank;
52. }
53. @Override
54. public void run() {
55. bank.getRMB();
56. }
57. }
60. class ThreadDollar implements Runnable{
61. private Bank bank;
62. public ThreadDollar(Bank bank){
63. this.bank = bank;
64. }
65. @Override
66. public void run() {
67. bank.getDollar();
68. }
69. }
72. class Bank{
73. public synchronized void getRMB(){
74. for(int i=0; i<20; i++){
75. try {
76. Thread.sleep((long)(Math.random()*1000));
77. } catch (InterruptedException e) {
78. e.printStackTrace();
79. }
80. System.out.println(Thread.currentThread().getName() + ":" + i);
81. }
82. }
84. public synchronized void getDollar(){
85. for(int i=0; i<20; i++){
86. try {
87. Thread.sleep((long)(Math.random()*1000));
88. } catch (InterruptedException e) {
89. e.printStackTrace();
90. }
91. System.out.println(Thread.currentThread().getName() + ":" + i);
92. }
93. }
94. }