Java多線程總結四：volatile、synchronized示例

1、synchronized保證同步

先看一個生成偶數的類

1. package demo.thread;
3. /**
4. *這是一個int生成器的抽象類
5. *
6. */
7. public abstract class IntGenerator {
9. private volatile boolean canceled = false;
11. public abstract int next();
13. public void cancel() {
14. canceled = true;
15. }
17. public boolean isCanceled() {
18. return canceled;
19. }
20. }

1. /*
2. * 產生偶數
3. */
4. class EvenGenerator extends IntGenerator {
5. private int currentEvenValue = 0;
6. String s = "";
8. @Override
9. public int next() {
10. <span style="color:#ff0000;">synchronized </span>(s) {
11. ++currentEvenValue;
12. ++currentEvenValue;
13. return currentEvenValue;
14. }
15. }
17. // //這樣也可以
18. // public <span >synchronized </span>int next() {
19. // ++currentEvenValue;
20. // ++currentEvenValue;
21. // return currentEvenValue;
22. // }
23. }

注意到在產生偶數是要加同步鎖，否則可能線程1剛好執行了一句++currentEvenValue;操作，就被線程2搶去了cpu，此時線程2執行return currentEvenValue;這時返回的就是一個奇數。加synchronized 就是兩個線程同時只能一個線程執行synchronized 塊的代碼。

測試代碼：

1. package demo.thread;
3. import java.util.concurrent.ExecutorService;
4. import java.util.concurrent.Executors;
6. /*
7. * 消費數字
8. */
9. public class EvenChecker implements Runnable {
11. private IntGenerator generator;
12. private final int id;
14. public EvenChecker(IntGenerator g, int ident) {
15. generator = g;
16. id = ident;
17. }
19. public void run() {
20. while (!generator.isCanceled()) {
21. int val = generator.next();
22. if (val % 2 != 0) {//如果不是偶數
23. System.out.println(val + " not enen!");
24. generator.cancel();
25. }
26. }
27. }
29. public static void test(IntGenerator gp, int count) {
30. ExecutorService exec = Executors.newCachedThreadPool();
31. for (int i = 0; i < count; i++)
32. exec.execute(new EvenChecker(gp, i));
33. exec.shutdown();
34. }
36. public static void test(IntGenerator gp) {
37. test(gp, 10);
38. }
40. public static void main(String[] args) {
41. test(new EvenGenerator());
42. }

分析：如果產生偶數的類未加synchronized，那麼測試程序將會出現奇數導致退出程序。