多线程安全问题的解决方法

三种方法：

同步代码块：

synchronized(obj)

{

        //obj表示同步监视器,是同一个同步对象

        /**.....

                TODO SOMETHING

        */

}

同步方法

格式：

在方法上加上synchronized修饰符即可。（一般不直接在run方法上加！）

synchronized 返回值类型 方法名(参数列表)

{

        /**.....

                TODO SOMETHING

        */

}

同步方法的同步监听器其实的是 this

静态方法的同步

同步方法

同步代码块

static不能和 this连用

静态方法的默认同步锁是当前方法所在类的.class对象

同步锁

jkd1.5后的另一种同步机制：

通过显示定义同步锁对象来实现同步，这种机制，同步锁应该使用Lock对象充当。

在实现线程安全控制中，通常使用ReentrantLock(可重入锁)。使用该对象可以显示地加锁和解锁。

具有与使用 synchronized 方法和语句所访问的隐式监视器锁相同的一些基本行为和语义，但功能更强大。

1. 
   
2. public class X {
   
3. private final ReentrantLock lock = new ReentrantLock();
   
4. //定义需要保证线程安全的方法
   
5. public void  m(){
   
6. //加锁
   
7. lock.lock();
   
8. try{
   
9. //... method body
   
10. }finally{
    
11. //在finally释放锁
    
12. lock.unlock();
    
13. }
    
14. }
    
15. }
    
16. 
    
17. 修改后的例子：
    
18. //同步代码块
    
19. package july7;
    
20. 
    
21. class SellDemo implements Runnable{
    
22. private int num = 50;
    
23. @Override
    
24. public void run() {
    
25. for (int i = 0; i < 200; i++) {
    
26. synchronized (this) {
    
27. if(num > 0){
    
28. try {
    
29. //因为它不可以直接调用getName()方法，所以必须要获取当前线程。
    
30. Thread.sleep(10);
    
31. } catch (InterruptedException e) {
    
32. e.printStackTrace();
    
33. }
    
34. System.out.println(Thread.currentThread().getName()+"卖出第"+num--+"张票！");
    
35. }
    
36. }
    
37. }
    
38. }
    
39. }
    
40. 
    
41. public class Demo3 {
    
42. public static void main(String[] args) {
    
43. SellDemo s = new SellDemo();
    
44. new Thread(s,"A").start();
    
45. new Thread(s,"B").start();
    
46. new Thread(s,"C").start();
    
47. }
    
48. }
    
49. 
    
50. 
    
51. //同步方法
    
52. package july7;
    
53. 
    
54. //同步方法
    
55. 
    
56. class FinalDemo1 implements Runnable {
    
57. private int num = 50;
    
58. 
    
59. @Override
    
60. public void run() {
    
61. for (int i = 0; i < 100; i++) {
    
62. gen();
    
63. }
    
64. }
    
65. 
    
66. public synchronized void gen() {
    
67. for (int i = 0; i < 100; i++) {
    
68. if (num > 0) {
    
69. try {
    
70. Thread.sleep(10);
    
71. } catch (InterruptedException e) {
    
72. e.printStackTrace();
    
73. }
    
74. System.out.println(Thread.currentThread().getName() + "卖出了第"
    
75. + num-- + "张票！");
    
76. }
    
77. }
    
78. }
    
79. }
    
80. 
    
81. public class Demo6 {
    
82. public static void main(String[] args) {
    
83. FinalDemo1 f = new FinalDemo1();
    
84. 
    
85. new Thread(f, "A").start();
    
86. new Thread(f, "B").start();
    
87. new Thread(f, "C").start();
    
88. 
    
89. }
    
90. }
    
91. 
    
92. 
    
93. //线程同步锁
    
94. package july7;
    
95. 
    
96. import java.util.concurrent.locks.ReentrantLock;
    
97. 
    
98. //同步锁
    
99. 
    
100. class FinalDemo2 implements Runnable {
     
101. private int num = 50;
     
102. private final ReentrantLock lock = new ReentrantLock();
     
103. @Override
     
104. public void run() {
     
105. for (int i = 0; i < 100; i++) {
     
106. gen();
     
107. }
     
108. }
     
109. 
     
110. public void gen() {
     
111. lock.lock();
     
112. try{
     
113. //for (int i = 0; i < 100; i++) {
     
114. if (num > 0) {
     
115. try {
     
116. Thread.sleep(10);
     
117. } catch (InterruptedException e) {
     
118. e.printStackTrace();
     
119. }
     
120. System.out.println(Thread.currentThread().getName() + "卖出了第"
     
121. + num-- + "张票！");
     
122. }
     
123. //}
     
124. }finally{
     
125. lock.unlock();
     
126. }
     
127. }
     
128. }
     
129. 
     
130. public class Demo7 {
     
131. public static void main(String[] args) {
     
132. FinalDemo2 f = new FinalDemo2();
     
133. 
     
134. new Thread(f, "A").start();
     
135. new Thread(f, "B").start();
     
136. new Thread(f, "C").start();
     
137. 
     
138. }
     
139. }

复制代码

多线程安全问题的解决方法

三种方法：

同步代码块：

synchronized(obj)

{

        //obj表示同步监视器,是同一个同步对象

        /**.....

                TODO SOMETHING

        */

}

同步方法

格式：

在方法上加上synchronized修饰符即可。（一般不直接在run方法上加！）

synchronized 返回值类型 方法名(参数列表)

{

        /**.....

                TODO SOMETHING

        */

}

同步方法的同步监听器其实的是 this

静态方法的同步

同步方法

同步代码块

static不能和 this连用

静态方法的默认同步锁是当前方法所在类的.class对象

同步锁

jkd1.5后的另一种同步机制：

通过显示定义同步锁对象来实现同步，这种机制，同步锁应该使用Lock对象充当。

在实现线程安全控制中，通常使用ReentrantLock(可重入锁)。使用该对象可以显示地加锁和解锁。

具有与使用 synchronized 方法和语句所访问的隐式监视器锁相同的一些基本行为和语义，但功能更强大。

1. 
   
2. public class X {
   
3. private final ReentrantLock lock = new ReentrantLock();
   
4. //定义需要保证线程安全的方法
   
5. public void  m(){
   
6. //加锁
   
7. lock.lock();
   
8. try{
   
9. //... method body
   
10. }finally{
    
11. //在finally释放锁
    
12. lock.unlock();
    
13. }
    
14. }
    
15. }
    
16. 
    
17. 修改后的例子：
    
18. //同步代码块
    
19. package july7;
    
20. 
    
21. class SellDemo implements Runnable{
    
22. private int num = 50;
    
23. @Override
    
24. public void run() {
    
25. for (int i = 0; i < 200; i++) {
    
26. synchronized (this) {
    
27. if(num > 0){
    
28. try {
    
29. //因为它不可以直接调用getName()方法，所以必须要获取当前线程。
    
30. Thread.sleep(10);
    
31. } catch (InterruptedException e) {
    
32. e.printStackTrace();
    
33. }
    
34. System.out.println(Thread.currentThread().getName()+"卖出第"+num--+"张票！");
    
35. }
    
36. }
    
37. }
    
38. }
    
39. }
    
40. 
    
41. public class Demo3 {
    
42. public static void main(String[] args) {
    
43. SellDemo s = new SellDemo();
    
44. new Thread(s,"A").start();
    
45. new Thread(s,"B").start();
    
46. new Thread(s,"C").start();
    
47. }
    
48. }
    
49. 
    
50. 
    
51. //同步方法
    
52. package july7;
    
53. 
    
54. //同步方法
    
55. 
    
56. class FinalDemo1 implements Runnable {
    
57. private int num = 50;
    
58. 
    
59. @Override
    
60. public void run() {
    
61. for (int i = 0; i < 100; i++) {
    
62. gen();
    
63. }
    
64. }
    
65. 
    
66. public synchronized void gen() {
    
67. for (int i = 0; i < 100; i++) {
    
68. if (num > 0) {
    
69. try {
    
70. Thread.sleep(10);
    
71. } catch (InterruptedException e) {
    
72. e.printStackTrace();
    
73. }
    
74. System.out.println(Thread.currentThread().getName() + "卖出了第"
    
75. + num-- + "张票！");
    
76. }
    
77. }
    
78. }
    
79. }
    
80. 
    
81. public class Demo6 {
    
82. public static void main(String[] args) {
    
83. FinalDemo1 f = new FinalDemo1();
    
84. 
    
85. new Thread(f, "A").start();
    
86. new Thread(f, "B").start();
    
87. new Thread(f, "C").start();
    
88. 
    
89. }
    
90. }
    
91. 
    
92. 
    
93. //线程同步锁
    
94. package july7;
    
95. 
    
96. import java.util.concurrent.locks.ReentrantLock;
    
97. 
    
98. //同步锁
    
99. 
    
100. class FinalDemo2 implements Runnable {
     
101. private int num = 50;
     
102. private final ReentrantLock lock = new ReentrantLock();
     
103. @Override
     
104. public void run() {
     
105. for (int i = 0; i < 100; i++) {
     
106. gen();
     
107. }
     
108. }
     
109. 
     
110. public void gen() {
     
111. lock.lock();
     
112. try{
     
113. //for (int i = 0; i < 100; i++) {
     
114. if (num > 0) {
     
115. try {
     
116. Thread.sleep(10);
     
117. } catch (InterruptedException e) {
     
118. e.printStackTrace();
     
119. }
     
120. System.out.println(Thread.currentThread().getName() + "卖出了第"
     
121. + num-- + "张票！");
     
122. }
     
123. //}
     
124. }finally{
     
125. lock.unlock();
     
126. }
     
127. }
     
128. }
     
129. 
     
130. public class Demo7 {
     
131. public static void main(String[] args) {
     
132. FinalDemo2 f = new FinalDemo2();
     
133. 
     
134. new Thread(f, "A").start();
     
135. new Thread(f, "B").start();
     
136. new Thread(f, "C").start();
     
137. 
     
138. }
     
139. }

复制代码