關于線程同步(7種方式)
?--如果朋友您想轉(zhuǎn)載本文章請注明轉(zhuǎn)載地址"http://www.cnblogs.com/XHJT/p/3897440.html"謝謝--?
為何要使用同步？?
1.同步方法?
??? 代碼如：?
???注： synchronized關鍵字也可以修飾靜態(tài)方法，此時如果調(diào)用該靜態(tài)方法，將會鎖住整個類
2.同步代碼塊?
??? 代碼如：?
????注：同步是一種高開銷的操作，因此應該盡量減少同步的內(nèi)容。?
package com.xhj.thread;/*** 線程同步的運用* * @author XIEHEJUN* */public class SynchronizedThread {class Bank {private int account = 100;public int getAccount() {return account;}/*** 用同步方法實現(xiàn)* * @param money*/public synchronized void save(int money) {account += money;}/*** 用同步代碼塊實現(xiàn)* * @param money*/public void save1(int money) {synchronized (this) {account += money;}}}class NewThread implements Runnable {private Bank bank;public NewThread(Bank bank) {this.bank = bank;}@Overridepublic void run() {for (int i = 0; i < 10; i++) {// bank.save1(10);bank.save(10);System.out.println(i + "賬戶余額為：" + bank.getAccount());}}}/*** 建立線程，調(diào)用內(nèi)部類*/public void useThread() {Bank bank = new Bank();NewThread new_thread = new NewThread(bank);System.out.println("線程1");Thread thread1 = new Thread(new_thread);thread1.start();System.out.println("線程2");Thread thread2 = new Thread(new_thread);thread2.start();}public static void main(String[] args) {SynchronizedThread st = new SynchronizedThread();st.useThread();}}
3.使用特殊域變量(volatile)實現(xiàn)線程同步
??? a.volatile關鍵字為域變量的訪問提供了一種免鎖機制，?
//只給出要修改的代碼，其余代碼與上同class Bank {//需要同步的變量加上volatileprivate volatile int account = 100;public int getAccount() {return account;}//這里不再需要synchronized public void save(int money) {account += money;}｝
????注：多線程中的非同步問題主要出現(xiàn)在對域的讀寫上，如果讓域自身避免這個問題，則就不需要修改操作該域的方法。?
??? 在JavaSE5.0中新增了一個java.util.concurrent包來支持同步。?
??? ReenreantLock類的常用方法有：
??????? ReentrantLock() : 創(chuàng)建一個ReentrantLock實例?
//只給出要修改的代碼，其余代碼與上同class Bank {private int account = 100;//需要聲明這個鎖private Lock lock = new ReentrantLock();public int getAccount() {return account;}//這里不再需要synchronized public void save(int money) {lock.lock();try{account += money;}finally{lock.unlock();}}｝
??? 注：關于Lock對象和synchronized關鍵字的選擇：?
??? ThreadLocal 類的常用方法
??? ThreadLocal() : 創(chuàng)建一個線程本地變量?
??? 例如：?
//只改Bank類，其余代碼與上同public class Bank{//使用ThreadLocal類管理共享變量accountprivate static ThreadLocal<Integer> account = new ThreadLocal<Integer>(){@Overrideprotected Integer initialValue(){return 100;}};public void save(int money){account.set(account.get()+money);}public int getAccount(){return account.get();}}
??? 注：ThreadLocal與同步機制?
6.使用阻塞隊列實現(xiàn)線程同步
??? 前面5種同步方式都是在底層實現(xiàn)的線程同步，但是我們在實際開發(fā)當中，應當盡量遠離底層結構。?
1 package com.xhj.thread;2 3 import java.util.Random;4 import java.util.concurrent.LinkedBlockingQueue;5 6 /**7 * 用阻塞隊列實現(xiàn)線程同步 LinkedBlockingQueue的使用8 * 9 * @author XIEHEJUN
10 *
11 */
12 public class BlockingSynchronizedThread {
13 /**
14 * 定義一個阻塞隊列用來存儲生產(chǎn)出來的商品
15 */
16 private LinkedBlockingQueue<Integer> queue = new LinkedBlockingQueue<Integer>();
17 /**
18 * 定義生產(chǎn)商品個數(shù)
19 */
20 private static final int size = 10;
21 /**
22 * 定義啟動線程的標志，為0時，啟動生產(chǎn)商品的線程；為1時，啟動消費商品的線程
23 */
24 private int flag = 0;
25
26 private class LinkBlockThread implements Runnable {
27 @Override
28 public void run() {
29 int new_flag = flag++;
30 System.out.println("啟動線程 " + new_flag);
31 if (new_flag == 0) {
32 for (int i = 0; i < size; i++) {
33 int b = new Random().nextInt(255);
34 System.out.println("生產(chǎn)商品：" + b + "號");
35 try {
36 queue.put(b);
37 } catch (InterruptedException e) {
38 // TODO Auto-generated catch block
39 e.printStackTrace();
40 }
41 System.out.println("倉庫中還有商品：" + queue.size() + "個");
42 try {
43 Thread.sleep(100);
44 } catch (InterruptedException e) {
45 // TODO Auto-generated catch block
46 e.printStackTrace();
47 }
48 }
49 } else {
50 for (int i = 0; i < size / 2; i++) {
51 try {
52 int n = queue.take();
53 System.out.println("消費者買去了" + n + "號商品");
54 } catch (InterruptedException e) {
55 // TODO Auto-generated catch block
56 e.printStackTrace();
57 }
58 System.out.println("倉庫中還有商品：" + queue.size() + "個");
59 try {
60 Thread.sleep(100);
61 } catch (Exception e) {
62 // TODO: handle exception
63 }
64 }
65 }
66 }
67 }
68
69 public static void main(String[] args) {
70 BlockingSynchronizedThread bst = new BlockingSynchronizedThread();
71 LinkBlockThread lbt = bst.new LinkBlockThread();
72 Thread thread1 = new Thread(lbt);
73 Thread thread2 = new Thread(lbt);
74 thread1.start();
75 thread2.start();
76
77 }
78
79 }
注：BlockingQueue<E>定義了阻塞隊列的常用方法，尤其是三種添加元素的方法，我們要多加注意，當隊列滿時：
add()方法會拋出異常
offer()方法返回false
put()方法會阻塞
7.使用原子變量實現(xiàn)線程同步
需要使用線程同步的根本原因在于對普通變量的操作不是原子的。
那么什么是原子操作呢？
1 class Bank {2 private AtomicInteger account = new AtomicInteger(100);3 4 public AtomicInteger getAccount() {5 return account;6 }7 8 public void save(int money) {9 account.addAndGet(money);
10 }
11 }?
補充--原子操作主要有：
總結
以上是生活随笔 為你收集整理的java笔记--关于线程同步（7种同步方式） 的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。
如果覺得生活随笔 網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔 推薦給好友。
