Â¥Ö÷

¹ØÓÚÓÃJAVAʵÏÖÉú²úÕß-Ïû·ÑÕß»úÖÆ [B][B]   ½üÈÕ,ѧУ²¼ÖÃÁËÒ»¶ÎÓÃJAVAʵÏÖÉú²úÕß-Ïû·ÑÕßÔ­ÀíµÄ´úÂë,ÒªÇóÉú²úÕßÊäÈëÒ»¶ÎÎÞ´óС˳ÐòµÄÊýÖµÀýÈç;5,7,8,0,.....È»ºóÏû·ÑÕßÒª°´´ÓСµ½´óµÄ˳Ðò¶Á³öÊýÖµ,Ò²ÒÔÉÏÃæÄǶÎÊýֵΪÀý×Ó,ÏÈÒª¶Á³ö5,¾ÍÒªÏȶÁ³ö0,Èç´ËÀàÍÆ.....Æ©Èç˵Éú²úÕß°Ñ"2"Õâ¸öÊý·Å½ø¶ÓÁÐÀïÃæ,ÕâʱºòÏû·ÑÕß²»ÄܶÁÈ¡,ÒòΪ"2"²»ÊÇ0µ½NÖ®ÖÐ×îСµÄÊýÖµ,ÕâʱºòÀ´¸ö"6",ͬÑùÏû·ÑÕß²»¶ÁÈ¡,"2""6"¾Í·ÅÔÚ¶ÓÁÐÀïÃæ,Ò»Ö±µÈµ½"0"³öÏÖ,Ïû·ÑÕ߲ŶÁÈ¡,µ±È»Ïû·ÑÕ߾͵ȴýÏÂÒ»¸öÏÂÒ»¸ö0µ½NÖеڶþСµÄÊýÄ¿----"1".ÔÚÕâÆÚ¼äÀ´µÄÆäÓàÊý×Ö¶¼·ÅÔÚ¶ÓÁÐÀïÃæµÈ´ý´¦Àí.   ÏÂÃæÊÇÎÒµÄÒ»¸öͬѧдµÄ´úÂë,ÓÐЩµØ·½¿´²»Ã÷°×,ÏëÇë½ÌÏ´ó¼Ò..... import java.util.*;          public class Queue {    private int length;    private int size;      private int[] values;    private int head;      private int last;    public Queue() {        this(100); } public Queue(int n) {          values = new int[n];        size = n;        length = 0;        head = -1;                                                        last = -1;                                                      //Õâ¸ö head ¸ú lastÔÚÕâÀïÓÐʲô×÷ÓÃ?  }     synchronized public void removeLowestValue()       //ÇëÎÊÕâ¸ö·½·¨ÎªÊ²Ã´ÒªÕâÑùд {      if(!isEmpty())      {          if(head != last)              head++;          if(head >= size)              head -= size;          //ÕâÀïÈç¹ûÁ½¸öIFÌõ¼þ²»³ÉÁ¢µÄ»°,·Ö±ð»áÌøתµ½ÄÄÀï?          length--;      }       }        synchronized public int getLowestValue()   {       if(!isEmpty())       {           return values[head];       }           return -1;       }        synchronized public boolean isEmpty()   {         return (length == 0);    }   synchronized public void addValue(int n)         //ÇëÎÊÕâ¸ö·½·¨ÎªÊ²Ã´ÒªÕâÑùд   {       if(length < size)                                      //ÔÚʲôÇé¿öÏ»álength < sizeÄØ?       {           if(isEmpty())           {               head++;           }           last++;           if(last >= size)               last -= size;                                         //ÕâÀïΪʲôҪÕâÑùʵÏÖ           values[last] = n;           length++;       }        } }   [/B][/B]    Êղؠ  ·ÖÏí   ¶¥(0)

	µÚ2Â¥

import java.util.*; /** An dieser Klasse duerfen keine Aenderungen vorgenommen werden. */ public class Producer extends Thread {     private final Queue q;                                    //ÕâÀïprivate finalÓÐʲô×÷ÓÃ?ΪʲôÕâÀï²»ÓÃNEW?    private final int   n;     public Producer(Queue q, int numInputValues) {         super();         this.q = q;         this.n = numInputValues;     }     public void run() {         int[] inputValues = new int[n];         for (int i = 0; i < n; i++) {             inputValues[i] = i;         }         // Generiert eine zufaellige Permutation         Random rng = new Random();         for (int j = 0; j < 10 * n; j++) {                          //ΪʲôÕâÀïÒª10 * nÄØ?            int pos1 = rng.nextInt(n);             int pos2 = rng.nextInt(n);             int buf = inputValues[pos1];             inputValues[pos1] = inputValues[pos2];             inputValues[pos2] = buf;                                   //ΪʲôÕâÀïÒª½»»»?         }         for (int i = 0; i < n; i++) {             System.out.println("Producer: Writing value " + inputValues[i]);             q.addValue(inputValues[i]);             try {                 sleep(10);             } catch (InterruptedException e) {                 e.printStackTrace();             }         }         System.out.println("Producer: "                 + "All values successfully written to the queue");     } }

	µÚ3Â¥

public class ConsumerBusyWaiting extends Thread {           private final int n;      private final Queue q;       /** Creates a new instance of ConsumerBusyWaiting */      public ConsumerBusyWaiting(Queue q,int numOutputValues) {          this.n = numOutputValues;          this.q = q;     }          public void run()     {         for(int i = 0;i < n;i++)         {             consume(q.getLowestValue());             q.removeLowestValue();             try             {                 sleep(10);             }             catch(Exception e)             {                 e.printStackTrace();             }         }         System.out.println("All values successlly read");     }     public void consume(int i)                                      //ΪʲôÕâ¸ö·½·¨¿ÉÒÔ·ÅÔÚºóÃ涨ÒåÄØ?    {         System.out.println("Consumer:Reading value" +i);     } }

	µÚ4Â¥

ÒÔϵĴúÂëÊÇÒªÇóÓùܳÌʵÏÖÏû·ÑÕßÔ­Àí,ÇëÎÊÏÂÃæÄǸöµØ·½ÌåÏÖÁ˹̵ܳÄ˼Ïë°¡? public class ConsumerMonitor extends Thread {          private final int n;     private final Queue q;          public ConsumerMonitor(Queue q ,int numOutputValues){         this.n = numOutputValues;         this.q = q;     }     public void run()     {         int anzahl = 0;         while(anzahl < n)         {             while(q.isEmpty())             {                 try                 {                     sleep(2);                 }                 catch(Exception e)                 {                     e.printStackTrace();                 }             }             consume(q.getLowestValue());             q.removeLowestValue();             anzahl++;         }                  }     public void consume(int i){              System.out.println("Consumer: Reading value" + i);     }     }

	µÚ5Â¥

/** An dieser Klasse duerfen keine Aenderungen vorgenommen werden. */ public class TestBusyWaiting {     public static final int LENGTH = 100;       public static void main(String[] args) {   Queue q = new Queue();   ConsumerBusyWaiting c = new ConsumerBusyWaiting(q, LENGTH);   Producer p = new Producer(q, LENGTH);      c.start();   p.start();     } }

	µÚ6Â¥

/** An dieser Klasse duerfen keine Aenderungen vorgenommen werden. */ public class TestMonitor {     public static final int LENGTH = 100;           public static void main(String[] args) {   Queue q = new Queue();   ConsumerMonitor c = new ConsumerMonitor(q, LENGTH);   Producer p = new Producer(q, LENGTH);      c.start();   p.start();     } }

	µÚ7Â¥

ÏÈлл´ó¼ÒÀ²~

	µÚ8Â¥

ûÓÐÈ˻شð?×Ô¼ºÔÙ¶¥~ÏÖÔÚÏëÖªµÀÔõÑùдÄǸögetLowestValue()µÄ³ÌÐò