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:

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!

Đã có app VietJack trên điện thoại, giải bài tập SGK, SBT Soạn văn, Văn mẫu, Thi online, Bài giảng....miễn phí. Tải ngay ứng dụng trên Android và iOS.

Theo dõi chúng tôi miễn phí trên mạng xã hội facebook và youtube:

Các bạn có thể mua thêm khóa học JAVA CORE ONLINE VÀ ỨNG DỤNG cực hay, giúp các bạn vượt qua các dự án trên trường và đi thực tập Java. Khóa học có giá chỉ 300K, nhằm ưu đãi, tạo điều kiện cho sinh viên cho thể mua khóa học.

Nội dung khóa học gồm 16 chuơng và 100 video cực hay, học trực tiếp tại https://www.udemy.com/tu-tin-di-lam-voi-kien-thuc-ve-java-core-toan-tap/ Bạn nào có nhu cầu mua, inbox trực tiếp a Tuyền, cựu sinh viên Bách Khoa K53, fb: https://www.facebook.com/tuyen.vietjack

Loạt bài hướng dẫn của chúng tôi dựa một phần trên nguồn tài liệu của: Tutorialspoint.com

Follow facebook cá nhân Nguyễn Thanh Tuyền https://www.facebook.com/tuyen.vietjack để tiếp tục theo dõi các loạt bài mới nhất về Java,C,C++,Javascript,HTML,Python,Database,Mobile.... mới nhất của chúng tôi.