libjava/testsuite/libjava.lang/Thread_Wait_2.java

   1 // Create many threads waiting on a monitor. Interrupt some of them. Do the
   2 // others wake up correctly with notify() and/or notifyAll()?
   3 // Origin: Bryce McKinlay <bryce@albatross.co.nz>
   4
   5 import java.util.Vector;
   6
   7 class Waiter extends Thread
   8 {
   9   Object monitor;
  10   int thread_num;
  11   boolean interrupted = false;
  12   boolean notified = false;
  13
  14   Waiter (Object monitor, int thread_num)
  15   {
  16     this.monitor = monitor;
  17     this.thread_num = thread_num;
  18   }
  19
  20   public void run()
  21   {
  22     synchronized (monitor)
  23       {
  24         try
  25         {
  26           monitor.wait();
  27           notified = true;
  28         }
  29         catch (InterruptedException x)
  30         {
  31           interrupted = true;
  32         }
  33       }
  34
  35   }
  36 }
  37
  38 public class Thread_Wait_2
  39 {
  40   static Vector threads;
  41   static Object monitor = new Object();
  42
  43   static final int NUM_THREADS = 10;
  44
  45   public static void main(String args[])
  46   {
  47
  48
  49     try
  50     {
  51       makeThreads ();
  52
  53       Thread.sleep(250);
  54
  55       // Interrupt a few threads...
  56       Waiter i1 = (Waiter) threads.elementAt(3);
  57       Waiter i2 = (Waiter) threads.elementAt(4);
  58       Waiter i3 = (Waiter) threads.elementAt(9);
  59       i1.interrupt();
  60       i2.interrupt();
  61       i3.interrupt();
  62
  63       // Call notify the exact number of times required to wake the remaining
  64       // threads.
  65       synchronized (monitor)
  66       {
  67         for (int i=0; i < NUM_THREADS -3 ; i++)
  68         {
  69           monitor.notify ();
  70         }
  71       }
  72
  73       joinAll();
  74       printStatus();
  75
  76       // Repeat all the above, but use notifyAll() instead.
  77       makeThreads();
  78
  79       Thread.sleep(250);
  80
  81       // Interrupt a few threads...
  82       i1 = (Waiter) threads.elementAt(0);
  83       i2 = (Waiter) threads.elementAt(1);
  84       i3 = (Waiter) threads.elementAt(9);
  85       i1.interrupt();
  86       i2.interrupt();
  87       i3.interrupt();
  88
  89       // Call notifyAll to wake the remaining threads.
  90       synchronized (monitor)
  91       {
  92         monitor.notifyAll ();
  93       }
  94
  95       joinAll();
  96       printStatus();
  97
  98     }
  99     catch (InterruptedException x)
 100     {
 101       System.out.println (x);
 102     }
 103
 104
 105   }
 106
 107   static void makeThreads()
 108   {
 109     threads = new Vector(NUM_THREADS);
 110
 111     for (int i=0; i < NUM_THREADS; i++)
 112       {
 113         Waiter w = new Waiter(monitor, i);
 114         w.start();
 115         threads.addElement(w);
 116       }
 117   }
 118
 119   static void joinAll()
 120   {
 121     try
 122     {
 123       for (int i=0; i < threads.size(); i++)
 124         {
 125           Thread t = (Thread) threads.elementAt(i);
 126           t.join();
 127         }
 128     }
 129     catch (InterruptedException x) {}
 130   }
 131
 132   static void printStatus()
 133   {
 134     for (int i=0; i < threads.size(); i++)
 135       {
 136         Waiter w = (Waiter) threads.elementAt(i);
 137         if (w.interrupted)
 138           System.out.println (i + " interrupted.");
 139         if (w.notified)
 140           System.out.println (i + " notified.");
 141       }
 142   }
 143
 144 }