JAVA小错积累(多线程)

今天学习JAVA的多线程，看书看到一半，心血来潮，写了个程序，错误百出，不过也巩固了知识，程序如下：

//Sell.java
import javax.swing.*;
import java.awt.event.*;
import java.awt.*;

public class Sell extends JFrame implements ActionListener {
 JTextArea    taOut;
 JButton      btnStart;
 JButton    btnStop;
 JTextField    jtf;
 Producethread produce;  
 Customthread  customer;
 Things     thing;
 JPanel        p1;
 JScrollPane   p;

 public Sell()
 {
  p1 = new JPanel();
  taOut = new JTextArea(20,30);
  p1.add(taOut);
  
  p = new JScrollPane(p1);
  p.setHorizontalScrollBarPolicy(JScrollPane.HORIZONTAL_SCROLLBAR_ALWAYS);
  p.setVerticalScrollBarPolicy(JScrollPane.VERTICAL_SCROLLBAR_ALWAYS);
  
  btnStart = new JButton("Start");
  btnStart.addActionListener(this);
  btnStop = new JButton("Stop");
  btnStop.addActionListener(this);
  
  jtf = new JTextField(6);
  
  getContentPane().add(p);
  getContentPane().add(jtf);
  getContentPane().add(btnStart);
  getContentPane().add(btnStop);
  getContentPane().setLayout(new FlowLayout());
  
  thing = new Things(taOut);
  
  setTitle("Sell Test");
  setBounds(100,0,370,460);
  setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
  setVisible(true);
 }
 
 public void actionPerformed(ActionEvent ae)
 {
  if (ae.getActionCommand().equals("Start"))
  {
   produce = new Producethread(thing);
   customer = new Customthread(thing);
   customer.setSpeed(jtf.getText());
   produce.start();
   customer.start();
  }
  if ( ae.getActionCommand().equals("Stop"))
  {
   produce.stop();
   customer.stop();
  }
 }
 
 public static void main(String[] args)
 {
  Sell se = new Sell();
 }
}

class Producethread extends Thread {
 Things th;
 
 public Producethread(Things thing)
 {
  th = thing;
 }
 
 public void run()
 {
  while(true)
  {
   th.addProduce();
   try{
    sleep(500);
   }
   catch(InterruptedException ie){
    System.err.println("ERR:" + ie.toString());
   }
  }
 }
}

class Customthread extends Thread {
 Things th;
 int sh;
 public Customthread(Things thing)
 {
  th = thing;
 }
 
 public void run()
 {
  while(true)
  {
   th.sellProduce();
   try{
    sleep((int)(Math.random()*sh));
   }
   catch(InterruptedException ie){
    System.err.println("ERR:" + ie.toString());
   }
  }
 }
 
 public void setSpeed(String s)
 {
  sh=Integer.parseInt(s)*2;
 }
}
   
class Things {
 JTextArea out;
 int total;
 private final static int MAX = 50;
 
 public Things(JTextArea taOut)
 {
  out=taOut;
  total=10;
 }
 
 public synchronized void addProduce()
 {
  try{
   if (total<MAX)
   {
    total++;
    out.append("生产一产品加入仓库\n库存："+ total + "\n");
   }else{
    out.append("满仓，暂停生产，等待中！\n");
    wait();
   }
  }
  catch(InterruptedException ie){
   System.err.println("ERR:" + ie.toString());
  }
  notify();
 }
 
 public synchronized void sellProduce()
 {
  try{
   if (total>0)
   {
    total--;
    out.append("出售一产品\n库存："+ total + "\n");
   }else{
    out.append("缺货，等待生产中!\n");
    wait();
   }
  }
  catch(InterruptedException ie){
   System.err.println("ERR:" + ie.toString());
  }
  notify();
 }
}

程序能够正确运行，按正常方式操作是没有问题的，但当连续按两次或一上Start的时候，问题就来了，在actionPerformed方法中，处理Start是重新实例化两个线程对象并运行，但如果这两个对象原来就在运行中，就会使旧的两个对象变成不受控制，不能停止了，修改方法可以在重新实例化前增加调用stop()方法。或增加一个变量，判断两个对象是否在运行，是就不执行重新实例化。

在测试中，发现了stop()方法调用后，是不能用start()方法重新另其启动的。(书上没有明确写出) 。连续调用同一个线程对象两次start()方法将会出错，stop()方法不会.

本文地址：http://com.8s8s.com/it/it16167.htm