吉大《java程序设计》复习资料（五）

100分

吉大《JAVA程序设计》拓展资源（五）
第五章 多线程
下面的Java的应用程序中，生产者线程向文件中写数据，消费者从文件中读数据，这样，在这个程序中同时运行的两个线程共享同一个文件资源。通过这个例子我们来了解怎样使它们同步。
class SyncStack  //同步堆栈类
{   private int index = 0; //堆栈指针初始值为0
     private char [] buffer = new char[6]; //堆栈有6个字符的空间
     public synchronized void push(char c) //加上互斥锁
     {   while( index == buffer.length ) //堆栈已满，不能压栈
         {   try{   this.wait(); //等待，直到有数据出栈}catch(InterruptedException e){} }
              this.notify(); //通知其它线程把数据出栈
              buffer[index] = c; //数据入栈   index++; //指针向上移动
         }
         public synchronized char pop() //加上互斥锁
         {   while(index ==0) //堆栈无数据，不能出栈
             {   try{   this.wait(); //等待其它线程把数据入栈   }
                 catch(InterruptedException e){ }   }
             this.notify(); //通知其它线程入栈
             index- -; //指针向下移动
             return buffer[index]; //数据出栈   }
}
class Producer implements Runnable //生产者类
{   SyncStack theStack;   //生产者类生成的字母都保存到同步堆栈中
     public Producer(SyncStack s)     {   theStack = s;    }
     public void run()
     {   char c;
          for(int i=0; i<20; i++)
         {   c =(char)(Math.random()*26+‘A’);  //随机产生20个字符
              theStack.push(c); //把字符入栈
              System.out.println(“Produced: ”+c); //打印字符
              try
              {   Thread.sleep((int)(Math.random()*1000));/*每产生一个字符线程就睡眠*/}
              catch(InterruptedException e){ }
          }
      }
}
class Consumer implements Runnable  //消费者类
{   SyncStack theStack;    //消费者类获得的字符都来自同步堆栈
     public Consumer(SyncStack s)   {   theStack = s;   }
     public void run()   
     {   char c;
          for(int i=0;i<20;i++)
          {   c = theStack.pop(); //从堆栈中读取字符
               System.out.println(“Consumed: ”+c); //打印字符
               try {   Thread.sleep((int)(Math.random()*1000));    }
               catch(InterruptedException e){ }
           }   }
}
public class SyncTest
{   public static void main(String args[])
    {   SyncStack stack = new SyncStack();
         //下面的消费者类对象和生产者类对象所操作的是同一个同步堆栈对象
         Runnable source = new Producer(stack);
         Runnable sink = new Consumer(stack);
         Thread t1 = new Thread(source); //线程实例化
         Thread t2 = new Thread(sink); //线程实例化
          t1.start(); //线程启动          t2.start(); //线程启动
     }
}
类Producer是生产者模型，其中的 run()方法中定义了生产者线程所做的操作，循环调用push()方法,将生产的20个字母送入堆栈中，每次执行完push操作后，调用sleep()方法睡眠一段随机时间，以给其他线程执行的机会。类Consumer是消费者模型，循环调用pop()方法,从堆栈中取出一个数据，一共取20次，每次执行完pop操作后，调用sleep()方法睡眠一段随机时间，以给其他线程执行的机会。
　　程序执行结果
　　　　　　　　Produced:V
　　　　　　　　Consumed:V
　　　　　　　　Produced:E
　　　　　　　　Consumed:E
　　　　　　　　Produced
　　　　　　　　Produced
　　　　　　　　...
　　　　　　　　Consumed
　　　　　　　　Consumed 奥鹏作业答案可以联系QQ 761296021