一个java多线程实例

import java.util.List;
import java.util.ArrayList;
import java.util.Queue;
import java.util.LinkedList;
public class Test3 {
    public static void main(String[] args) {
        final Manager3 m3 = new Manager3();
        m3.init();
        Thread t1 = new Thread(new Runnable() {
            public void run() {
                while (true) {
                    if (m3.getter.q.size() > 0) {
                        TestData3 td = m3.getter.q.pop();
                        System.out.println(td.getName());
                    } else {
                        try {wait();} catch (Exception e) {}
                    }
                }
            }
        });
        t1.start();
    }
}
class TestData3 {
    String type;
    String id;
    String name;
    TestData3(String type, String id, String name) {
        this.type = type;
        this.id = id;
        this.name = name;
    }
    String getName() {
        return name;
    }
}
class TestDataQueue3 {
    Queue<TestData3> q = new LinkedList<TestData3>();
    void push(TestData3 td) {
        q.offer(td);
    }
    TestData3 pop() {
        return q.poll();
    }
    long size() {
        return q.size();
    }
}
class Manager3 {
    Getter3 getter = new Getter3();
    Setter3 setter = new Setter3();
    Adapter3 adapter = Setter3.adapter;
    void init() {
        adapter.addGetter(getter);
        setter.regist();
        setter.putData();
        adapter.listenData();
    }
}
class Getter3 {
    TestDataQueue3 q = new TestDataQueue3();
    void update(TestData3 data) {
        q.push(data);
    }
}
class Adapter3 {
    TestDataQueue3 q = new TestDataQueue3();
    List<Getter3> glst = new ArrayList<Getter3>();
    List<Setter3> slst = new ArrayList<Setter3>();
    void addGetter(Getter3 g) {
        glst.add(g);
    }
    void addSetter(Setter3 s) {
        slst.add(s);
    }
    void listenData() {
        Thread t = new Thread(new Runnable() {
            public void run() {
                while (true) {
                    if (q.size() > 0) {
                        broadcast(q.pop());
                    } else {
                        try {
                            wait();
                        } catch (Exception e) {}
                    }
                }
            }
        });
        t.start();
    }
    void broadcast(TestData3 td) {
        for (int i = 0; i < glst.size(); i++) {
            glst.get(i).update(td);
        }
    }
}
class Setter3 {
    static final Adapter3 adapter = new Adapter3();
    void regist() {
        adapter.addSetter(this);
    }
    void putData() {
        Thread t = new Thread(new Runnable() {
            public void run() {
                int i = 0;
                while (true) {
                    TestData3 td = new TestData3("computer", "c" + String.format("%08d", i), "computer" + i);
                    adapter.q.push(td);
                    i++;
                    try {
                        Thread.sleep(1000);
                        notify();
                    } catch (Exception e) {}
                }
            }
        });
        t.start();
    }
}