多线程初学
- 该模式是生产者--消费者模式。
- 规定了两个任务内部类，Consumer 和Producer .
- Producer负责给 num 加1，Consumer 负责给num 减 1。
- run()方法只是负责任务，不负责启动。
- 通过 new Thread(new Producer()) 将任务分配给线程。通过start()方法开启线程。
- Main 线程中有 线程Consumer 的实例consumer ,以及Producer 的实例 producer,所以可以说看的到另外两个线程，所以可以对其他线程进行一定程度的操作。
- consumer ,producer不知道Main线程，彼此也不知道，所以可以通过Main线程作为中介，使之发生联系。比如说，在main中，将producer传给consumer（一般不建议这么做。），可以使用监听者模式。
-
synchronized注意同步，为了正确共享资源。
代码如下：
package tree.test.testThread;
import java.util.Observable;
import java.util.Observer;
public class TestConsumer {
public static int num = 0;
public final static int CONSUMER_SLEEP_TIME = 50;
public final static int PRODUCER_SLEEP_TIME = 40;
@SuppressWarnings("deprecation")
public static void main(String[] args) {
System.out.println("started `````");
Thread consumer = new Thread(new Consumer());
Thread producer = new Thread(new Producer());
consumer.start();
producer.start();
try {
Thread.sleep(2000);
Thread.yield();
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println("ended `````");
//TODO main thread tell others to stop
consumer.stop();
producer.stop();
}
static class Producer implements Runnable,Observer {
public void run() {
synchronized (this) {
while (true) {
num++;
System.out.println("after produce , num = " + num);
try {
Thread.sleep(PRODUCER_SLEEP_TIME);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}
public void update(Observable o, Object arg) {
//TODO how to use the pattern observer to control the thread end time .
}
}
static class Consumer implements Runnable {
public void run() {
synchronized (this) {
while (true) {
try {
if (num > 0) {
num--;
System.out.println("after consume , num = " + num);
} else {
System.out.println("nothing in the pool !!");
}
Thread.sleep(CONSUMER_SLEEP_TIME);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}
}
}