Interthread Communication trong Java

---

---

Nếu bạn đã biết về giao tiếp liên tiến trình (interprocess communication), thì nó sẽ dễ dàng cho bạn hiểu về inter-thread communication. Inter-thread communication là quan trọng khi bạn phát triển một ứng dụng mà có hai hoặc nhiều thread trao đổi một số thông tin.

Để hiểu sâu hơn các khái niệm được trình bày trong chương này, mời bạn tham khảo loạt bài: Ví dụ về Thread trong Java.

Dưới đây là 3 phương thức đơn giản:

STT	Phương thức và Miêu tả
1	public void wait() Làm thread hiện tại đợi tới khi thread khác triệu hồi notify()
2	public void notify() Báo cho một thread đơn mà đang đợi trên monitor của đối tượng
3	public void notifyAll() Báo cho tất cả thread mà gọi wait( ) trên cùng một đối tượng

Các phương thức này đã được triển khai ở dạng phương thức final trong Object, vì thế chúng là có sẵn trong tất cả các lớp. Tất cả 3 phương thức này chỉ có thể được gọi từ trong một ngữ cảnh synchronized.

Ví dụ

Sau đây là ví dụ minh họa 2 thread có thể giao tiếp bởi sử dụng phương thức wait() và notify(). Bạn có thể tạo một hệ thống phức tạp bởi sử dụng cùng khái niệm đó.

class Chat {
    boolean flag = false;    public synchronized void Question(String msg) {
        if (flag) {
            try {
                wait();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
        System.out.println(msg);
        flag = true;
        notify();
    }    public synchronized void Answer(String msg) {
        if (!flag) {
            try {
                wait();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }        System.out.println(msg);
        flag = false;
        notify();
    }
}class T1 implements Runnable {
    Chat m;
    String[] s1 = { "Hi", "How are you ?", "I am also doing fine!" };    public T1(Chat m1) {
        this.m = m1;
        new Thread(this, "Question").start();
    }    public void run() {
        for (int i = 0; i < s1.length; i++) {
            m.Question(s1[i]);
        }
    }
}class T2 implements Runnable {
    Chat m;
    String[] s2 = { "Hi", "I am good, what about you?", "Great!" };    public T2(Chat m2) {
        this.m = m2;
        new Thread(this, "Answer").start();
    }    public void run() {
        for (int i = 0; i < s2.length; i++) {
            m.Answer(s2[i]);
        }
    }
}
public class TestThread {
    public static void main(String[] args) {
        Chat m = new Chat();
        new T1(m);
        new T2(m);
    }
}

Khi chương trình trên được biên dịch và thực thi, nó cho kết quả sau:

Hi
Hi
How are you ?
I am good, what about you?
I am also doing fine!
Great!

---

---

---