###### tags: `database`

# Java Concurrency

作業系統學到的同步化知識，Java 內建就有，以下讓我們窺其一二。

## 使用 Thread

建立執行緒

1. 實作 Runnable

    public class SomeRunnable implements Runnable {
    		@Override
    		public void run() { /* ... */ }
    }

2. 繼承 Thread

    public class SomeThread extends Thread {
    		@Override
    		public void run() { /* ... */ }
    }

3. 使用

    var runnableThread = new Thread(new SomeRunnable());
    runnableThread.start();

    var myThread = new SomeThread();
    myThread.start();

新執行緒的 Function Call 會在新的 Stack 上運作，與當前 Stack 分離。

## 同步化議題

有別於 Fork Process，Heap 上的記憶體是各個 Thread 共享的（Share Memory），故會有 Race Condition。

Java 提供兩種 Race Condition 的解決方法。

> 以下兩者等價。
>
1. Monitor 風格
對方法同步，也就是一次只能有一個 Thread 可以使用需要同步的方法。

    public class MonitorCounter {
        private int shared_var;
    
        public synchronized void set(int val) {
            shared_var = val;
        }
        
        public synchronized int get() {
            return shared_var;
        }
    }

2. Critical Section 風格
對 Heap Memory 上的物件同步。
因為 Java 的物件都在 Heap 上，故將 `this` 放入就等於一次只能有一個 Thread 呼叫這倆要同步的方法。

    public class SyncCounter {
        private int shared_var;
    
        public void set(int val) {
            synchronized(this) {
                shared_var = val;
            }
        }
        
        public synchronized int get() {
            synchronized(this) {
                return shared_var;
            }
        }
    }

不過最重要的是，要清楚 Critical Section 真正的範圍。以下就算用上面方法上同步化的物件也沒用。

counter = new SyncCounter(); // shared_var = 0
// Thread 1
int c = counter.get();
++c;
counter.set(c);
// Thread 2
int c = counter.get();
--c;
counter.set(c);
// The result of shared_var can be 0, 1, -1...
// because te real critical section is the whole get-and-set process!

解決方法有二，一是使用者把使用者的操作也納入 Critical Section，二是物件提供同步化的 get-and-set 的方法。

## Semaphore 的使用: `wait` 和 `notify`

**Java 的所有物件都內建 semaphore 的邏輯！！！**

如果某 Thread 得不到需要的物件資源，可以主動呼叫該物件的 `Object::wait` 方法將執行權讓給其他 Thread；當某 Thread 釋放此物件資源時可以呼叫 `Object::notifyAll` 方法喚醒「所有」在等待此資源的 Thread，當中的「某一個」物件將會獲得此物件的使用權。注意這裡說「物件的使用權」是自訂義的，Java 並不會限制物件的使用。

另注意，`Object::wait` 方法總是習慣被包在回圈中，因為只有「某一個」想使用物件的 Thread 可以真的獲得之。