Java多线程之synchronized

Java多线程之synchronized

这里通过三个测试类阐述了synchronized应用的不同场景

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

1. package com.jadyer.thread.sync; 
2.  
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.bkjia.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(); 
33.          
34.         Thread tt11 = new Thread(new ThreadRMB(bank)); 
35.          
36.         //new一个新的Bank对象。此时存在两个Bank对象，并且它们属于同一个类的不同的对象  
37.         //如要验证多个线程操作同一个类的不同的对象的synchronized方法，只需取消注释该行代码即可  
38.         //bank = new Bank();  
39.          
40.         Thread tt22 = new Thread(new ThreadDollar(bank)); 
41.          
42.         tt11.start(); 
43.         tt22.start(); 
44.     } 
45. } 
46.  
47.  
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. } 
58.  
59.  
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. } 
70.  
71.  
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.     } 
83.      
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. }