线程交替运行，一个写，一个读。

atell

浏览: 161675 次
性别:
来自: 杭州

最近访客更多访客>>

hq804116393

bupt04406

e9999e

henshuang

博主相关

博客

微博

相册

留言

关于我

文章分类

全部博客 (73)

社区版块

存档分类

thread

import java.util.Stack;

public class SynchronizedTest {

    public static void main(String[] args) {
        Stack<String> s = new Stack<String>();
        Thread t1 = new Producer(s);
        t1.start();
        Thread t2 = new Consumer(s);
        t2.start();
    }

}

class Consumer extends Thread {

    Stack<String> s;

    public Consumer(Stack<String> s) {
        this.s = s;
    }

    @Override
    public void run() {
        while (true) {
            synchronized (s) {
                while (s.empty()) {
                    try {
                        s.wait();
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                }
                System.out.println("pop:" + s.pop());
                s.notify();
            }
        }
    }

}

class Producer extends Thread {
    Stack<String> s;

    public Producer(Stack<String> s) {
        this.s = s;
    }

    @Override
    public void run() {
        while (true) {
            synchronized (s) {
                while (!s.empty()) {
                    try {
                        s.wait();
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                }
                System.out.println("push:" + s.push("a"));
                s.notify();
            }
        }
    }

}

输出：

push:a
pop:a
push:a
pop:a

......

或者：

import java.util.Stack;

public class SynchronizedTest {

    public static void main(String[] args) {
        Data data = new Data();
        Thread t1 = new Producer(data);
        t1.start();
        Thread t2 = new Consumer(data);
        t2.start();
    }

}

class Data {
    Stack<String> s = new Stack<String>();

    public synchronized void read() {
        while (s.empty()) {
            try {
                wait();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
        System.out.println("pop:" + s.pop());
        notify();
    }

    public synchronized void write() {
        while (!s.empty()) {
            try {
                wait();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
        System.out.println("push:" + s.push("a"));
        notify();
    }
}

class Consumer extends Thread {

    Data data;

    public Consumer(Data data) {
        this.data = data;
    }

    @Override
    public void run() {
        while (true) {
            data.read();
        }
    }

}

class Producer extends Thread {
    Data data;

    public Producer(Data data) {
        this.data = data;
    }

    @Override
    public void run() {
        while (true) {
            data.write();
        }
    }

}

分享到：