多线程学习——消费者生产者（1）

package com.daicy.ProducerConsumer;

import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;

public class ProducerConsumer {
public static void main(String[] args) {
executorThreads();
// baseThreads();
}

public static void executorThreads() {
IDStack stack = new DLinkedBlockingQueue<Mantou>();
ExecutorService exec = Executors.newFixedThreadPool(3);
exec.execute(new Consumer(stack));
exec.execute(new Consumer(stack));
exec.execute(new Producer(stack));
exec.execute(new Consumer(stack));
exec.execute(new Producer(stack));
// shutdownAndAwaitTermination(exec);
try {
TimeUnit.MILLISECONDS.sleep(10);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} // Run for a while...
exec.shutdownNow(); // Interrupt all tasks
// new Thread(new Consumer(stack)).start();
// new Thread(new Producer(stack)).start();
//
// new Thread(new Producer(stack)).start();
// new Thread(new Consumer(stack)).start();
}

public static void shutdownAndAwaitTermination(ExecutorService pool) {
pool.shutdown(); // Disable new tasks from being submitted
try {
// Wait a while for existing tasks to terminate
if (!pool.awaitTermination(60, TimeUnit.MILLISECONDS)) {
pool.shutdownNow(); // Cancel currently executing tasks
// Wait a while for tasks to respond to being cancelled
if (!pool.awaitTermination(60, TimeUnit.MILLISECONDS))
System.err.println("Pool did not terminate");
}
} catch (InterruptedException ie) {
// (Re-)Cancel if current thread also interrupted
pool.shutdownNow();
// Preserve interrupt status
Thread.currentThread().interrupt();
}
}

public static void baseThreads() {
IDStack stack = new DLinkedBlockingQueue<Mantou>();
List<Thread> list = new ArrayList();
list.add(new Thread(new Consumer(stack)));
list.add(new Thread(new Producer(stack)));
list.add(new Thread(new Producer(stack)));
list.add(new Thread(new Consumer(stack)));
for (int i = 0; i < list.size(); i++) {
list.get(i).start();
}

try {
TimeUnit.MILLISECONDS.sleep(10);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} // Run for a while...

for (int i = 0; i < list.size(); i++) {
list.get(i).interrupt();
}

// for (int i = 0; i < list.size(); i++) {
// list.get(i).stop();
// }
}
}

package com.daicy.ProducerConsumer;

public class Consumer implements Runnable {
private IDStack<Mantou> stack;

private static int taskCount;

private final int id = taskCount++;

public Consumer(IDStack<Mantou> stack) {
this.stack = stack;
// TODO Auto-generated constructor stub
}

@Override
public void run() {
// TODO Auto-generated method stub
// while (true) {
while (!Thread.interrupted()) {
try {
Mantou mantou = stack.pop();
System.out.println("C" + this.id + " 消费了 mantou" + mantou);
// Thread.sleep((long) (Math.random() * 1000));
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
System.out.println("C" + this.id + " 消费了ttttt mantou");
break;
}
}

}
}

package com.daicy.ProducerConsumer;

import com.daicy.sequence.SafeSequence;

public class Producer implements Runnable {

private IDStack<Mantou> stack;

private static int taskCount;

private final int id = taskCount++;

public Producer(IDStack<Mantou> stack) {
this.stack = stack;
// TODO Auto-generated constructor stub
}

@Override
public void run() {
// TODO Auto-generated method stub
// while (true) {
while (!Thread.interrupted()) {
try {
int id = SafeSequence.getNext();
Mantou mantou = new Mantou(id);
stack.push(mantou);
System.out.println("P" + this.id + " 生产了 mantou" + mantou);
// Thread.sleep((long) (Math.random() * 1000));
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
System.out.println("P" + this.id + " 生产了 tttmantou");
break;
}
}
}
}