等待唤醒机制

妖狐艹你老母 2022-08-09 09:28 238阅读 0赞

package comm;
    
    class Res { 
        String name;
        String sex;
        boolean flag = false;
    }
    
    class Input implements Runnable { 
        private Res r;
    
        public Input(Res r) {
            this.r = r;
        }
    
        public void run() {
            int x = 0;
            while (true) {
    
                synchronized (r) {
    
                    if (r.flag)
                        try {
                            r.wait();
                        } catch (InterruptedException e) {
                        }
                    if (x == 0) {
                        r.name = "mike";
                        r.sex = "man";
                    } else {
                        r.name = "丽丽";
                        r.sex = "女女女";
                    }
                    x = (x + 1) % 2;
                    r.flag = true;
                    r.notify();
                }
            }
        }
    }
    
    class Output implements Runnable { 
        private Res r;
    
        public Output(Res r) {
            this.r = r;
        }
    
        public void run() {
            while (true)
                synchronized (r) {
                    if (!r.flag)
                        try {
                            r.wait();
                        } catch (InterruptedException e) {
                        }
                    System.out.println(r.name + " , " + r.sex);
                    r.flag = false;
                    r.notify();
                }
        }
    }
    
    public class InputOutoutDemo { 
    
        public static void main(String[] args) {
    
            Res r = new Res();
            Input in = new Input(r);
            Output out = new Output(r);
            Thread t1 = new Thread(in);
            Thread t2 = new Thread(out);
            t1.start();
            t2.start();
        }
    }