3 Java并发线程间通信

作者: 笑Skr人啊 | 来源:发表于2017-08-30 17:45 被阅读8次

    如果你知道进程间通信,那么就很容易理解线程间通信。 当您开发两个或多个线程交换一些信息的应用程序时,线程间通信很重要。

    有三个简单的方法和一个小技巧,使线程通信成为可能。 所有三种方法都列在下面 -

    编号 方法 描述
    1 public void wait() 使当前线程等到另一个线程调用notify()方法。
    2 public void notify() 唤醒在此对象监视器上等待的单个线程。
    3 public void notifyAll() 唤醒所有在同一个对象上调用wait()的线程。

    这些方法已被实现为Object中的最终(final)方法,因此它们在所有类中都可用。 所有这三种方法只能从同步上下文中调用。

    实例

    这个例子显示了两个线程如何使用wait()和notify()方法进行通信。 您可以使用相同的概念来创建一个复杂的系统。

    
    package ThreadMethod;
    
    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,I am Question", "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 Answer", "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 ThreadCommunication {
       public static void main(String[] args) {
          Chat m = new Chat();
          new T1(m);
          new T2(m);
       }
    }
    

    执行

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

    相关文章

      网友评论

        本文标题:3 Java并发线程间通信

        本文链接:https://www.haomeiwen.com/subject/atsxjxtx.html