天天看點

Java線程安全:Synchronized關鍵字實作線程同步

作者:運維開發木子李

#頭條創作挑戰賽#

在Java程式中,可以通過以下幾種方式來保證多線程的運作安全:

  1. 使用synchronized關鍵字:可以将關鍵代碼塊或方法聲明為synchronized,以確定同一時間隻有一個線程可以執行該代碼塊或方法。
  2. 使用Lock鎖:可以使用Java的Lock接口及其實作類,如ReentrantLock,來手動控制線程的通路權限,確定在一個線程通路共享資源時,其他線程無法通路。
  3. 使用volatile關鍵字:可以使用volatile關鍵字來修飾變量,確定該變量的可見性,即當一個線程修改了該變量的值後,其他線程能夠立即看到最新的值。
  4. 使用線程安全的資料結構:Java提供了一些線程安全的資料結構,如ConcurrentHashMap、CopyOnWriteArrayList等,可以避免多線程并發通路時的資料安全問題。
  5. 使用線程安全的類庫:在編寫多線程程式時,應盡量使用Java提供的線程安全的類庫,如AtomicInteger、AtomicLong等,這些類庫的方法都是原子操作,可以保證多線程環境下的安全通路。
  6. 避免共享資料:盡量避免多個線程之間共享資料,如果必須共享資料,要考慮如何進行合理的同步控制,以確定資料的一緻性和安全性。

在Java中,synchronized關鍵字用于實作線程的同步,確定多個線程之間對共享資源的通路是安全的。synchronized關鍵字有兩種使用方式:

synchronized關鍵字有兩種使用方式:

    1. 修飾方法:将synchronized關鍵字直接修飾一個方法,表示整個方法是一個臨界區,隻能同時被一個線程通路。
    2. 修飾代碼塊:将synchronized關鍵字修飾一個代碼塊,在代碼塊内部的部分代碼稱為臨界區,隻能同時被一個線程通路。

當我們在Java中使用synchronized關鍵字時,它的主要功能是確定一段代碼在同一時間隻能由一個線程執行。這可以有效地解決多線程并發通路共享資源時可能出現的競态條件和資料不一緻性問題。

Synchronized關鍵字功能示例:

Java線程安全:Synchronized關鍵字實作線程同步

同步執行個體方法:

class Counter {
    private int count = 0;

    public synchronized void increment() {
        count++;
    }

    public synchronized void decrement() {
        count--;
    }
}           

同步靜态方法:

class Counter {
    private static int count = 0;

    public static synchronized void increment() {
        count++;
    }

    public static synchronized void decrement() {
        count--;
    }
}           

同步代碼塊:

class Counter {
    private int count = 0;
    private Object lock = new Object();

    public void increment() {
        synchronized (lock) {
            count++;
        }
    }

    public void decrement() {
        synchronized (lock) {
            count--;
        }
    }
}           

鎖定不同的對象:

class Counter {
    private int count = 0;
    private Object lock1 = new Object();
    private Object lock2 = new Object();

    public void increment() {
        synchronized (lock1) {
            count++;
        }
    }

    public void decrement() {
        synchronized (lock2) {
            count--;
        }
    }
}           

同步靜态變量:

class Counter {
    private static int count = 0;
    private static Object lock = new Object();

    public static void increment() {
        synchronized (lock) {
            count++;
        }
    }

    public static void decrement() {
        synchronized (lock) {
            count--;
        }
    }
}           

同步集合類:

List<Integer> synchronizedList = Collections.synchronizedList(new ArrayList<>());
Set<Integer> synchronizedSet = Collections.synchronizedSet(new HashSet<>());
Map<Integer, String> synchronizedMap = Collections.synchronizedMap(new HashMap<>());           

同步方法内部的代碼塊:

class Counter {
    private int count = 0;

    public void increment() {
        synchronized (this) {
            count++;
        }
    }

    public void decrement() {
        synchronized (this) {
            count--;
        }
    }
}           

同步調用其他對象的方法:

class Counter {
    private int count = 0;
    private OtherObject otherObject = new OtherObject();

    public synchronized void increment() {
        count++;
        otherObject.doSomething();
    }

    public synchronized void decrement() {
        count--;
        otherObject.doSomething();
    }
}

class OtherObject {
    public synchronized void doSomething() {
        // 執行一些操作
    }
}           

使用ReentrantLock實作同步:

import java.util.concurrent.locks.ReentrantLock;

class Counter {
    private int count = 0;
    private ReentrantLock lock = new ReentrantLock();

    public void increment() {
        lock.lock();
        try {
            count++;
        } finally {
            lock.unlock();
        }
    }

    public void decrement() {
        lock.lock();
        try {
            count--;
        } finally {
            lock.unlock();
        }
    }
}           

使用synchronized修飾方法參數:

class Counter {
    private int count = 0;

    public void increment() {
        synchronized (this) {
            count++;
        }
    }

    public void decrement() {
        synchronized (this) {
            count--;
        }
    }

    public synchronized void modifyCount(int value) {
        count += value;
    }
}           

使用synchronized修飾類的靜态初始化塊:

class Counter {
    private static int count;

    static {
        synchronized (Counter.class) {
            count = 0;
        }
    }
}           

使用synchronized修飾類的執行個體初始化塊:

class Counter {
    private int count;

    {
        synchronized (this) {
            count = 0;
        }
    }
}           

使用synchronized修飾靜态變量的初始化:

class Counter {
    private static int count = 0;

    static {
        synchronized (Counter.class) {
            count = 0;
        }
    }
}           

使用synchronized修飾靜态方法的參數:

class Counter {
    private static int count;

    public static synchronized void increment(int value) {
        count += value;
    }
}           

使用synchronized修飾代碼塊的參數:

class Counter {
    private int count;

    public void increment(int value) {
        synchronized (this) {
            count += value;
        }
    }
}           

繼續閱讀