IllegalMonitorStateException mit zwei threads

Mein Programm hat zwei Threads, jeder druckt zehn zahlen. Der erste Thread, druckt die ungeraden Anzahl, der zweite Thread druckt die gerade Zahl ist, und Sie abwechselnd den Druck zahlen. Ich bin erwartet man eine Sequenz wie 1,2,3,4,5....bis 20, aber das Programm erzeugt eine IllegalMonitorStateException.

Ich weiß, was diese Exception bedeutet, aber ich benutze wait() und notify() im synchronisierten block. Hier ist mein code:

     public class EvenOddThreadTest {

      /**
       * @param args
       */
      static Object obj1 = new Object();
      static Object obj2 = new Object();
      static Object obj3=new EvenOddThreadTest();

      public static void main(String[] args) throws InterruptedException {
          new Thread() {
              @Override
              public void run() {

                      for (int i = 1; i < 21; i += 2) {
                          synchronized (obj1) {
                          System.out.println(i + Thread.currentThread().getName());
                          try {
                              obj2.notify();                    
                              obj1.wait();
                          } catch (InterruptedException e) {
                              e.printStackTrace();
                          }

                      }
                  }
              }
          }.start();
          new Thread() {
              @Override
              public void run() {
                      for (int i = 2; i < 21; i += 2) {
                          synchronized (obj2) {

                          System.out.println(i + Thread.currentThread().getName());
                        try {
                            obj1.notify();
                            obj2.wait();
                        } catch (InterruptedException e) {
                            e.printStackTrace();
                        }
                    }
                }
            }

            }.start();
        }
    }

- und das ist die Ausnahme generiert:

1Thread-0
2Thread-1
Exception in thread "Thread-0" java.lang.IllegalMonitorStateException
    at java.lang.Object.notify(Native Method)
    at EvenOddThreadTest$1.run(EvenOddThreadTest.java:21)
Exception in thread "Thread-1" java.lang.IllegalMonitorStateException
    at java.lang.Object.notify(Native Method)
    at EvenOddThreadTest$2.run(EvenOddThreadTest.java:41)

Kann ich nicht verstehen. Irgendwelche Ideen?

InformationsquelleAutor Wei JingNing | 2012-03-01
  1. 5

    Können Sie nicht, rufen Sie Benachrichtigen auf ein Objekt, dessen monitor, die Sie nicht besitzen:

                   synchronized (obj1) {
                  System.out.println(i + Thread.currentThread().getName());
                  try {
                      obj2.notify();  //You haven't synchronized on obj2
    InformationsquelleAutor artbristol
  2. 4

    Beiden threads synchronisieren müssen auf die gleiche variable, wenn Sie zusammen arbeiten. Was Sie wollen, ist für eine zu warten, bis seine Runde zu laufen, dann laufen, dann hat den anderen thread.

    public class EvenOddThreadTest {

  /**
   * @param args
   */
  static Object obj1 = new Object();
  static Object obj3=new EvenOddThreadTest();

  public static void main(String[] args) throws InterruptedException {
      new Thread() {
          @Override
          public void run() {

                  for (int i = 1; i < 21; i += 2) {
                      synchronized (obj1) {
                      try {
                          while (/* not my turn to run *?*/) {                   
                             obj1.wait();
                          }
                      } catch (InterruptedException e) {
                          e.printStackTrace();
                      }
                      System.out.println(i + Thread.currentThread().getName());
                      obj1.notify();
                  }
              }
          }
      }.start();
      new Thread() {
          @Override
          public void run() {
                  for (int i = 2; i < 21; i += 2) {
                      synchronized (obj1) {
                      try {
                          while (/* not my turn to run *?*/) {                   
                             obj1.wait();
                          }
                      } catch (InterruptedException e) {
                          e.printStackTrace();
                      }
                      System.out.println(i + Thread.currentThread().getName());
                      obj1.notify();
                }
            }
        }

        }.start();
    }
}
    InformationsquelleAutor Michael Krussel
  3. 0

    In thread 0 Sie sind nur synchronisieren auf die obj2 nicht obj1 auf die Sie aufrufen notify. Im zweiten thread ist es die andere Weise herum.

    InformationsquelleAutor Marc-Christian Schulze
  4. 0

    Diese keine Antwort auf Ihre Frage nicht direkt, aber Threads sind ziemlich low-level. In Ihrem Fall könnten Sie zum Beispiel mit einem CyclicBarrier, die sich um die Synchronisierung details für Sie:

    public class Test {

    static CyclicBarrier barrier = new CyclicBarrier(2);

    public static void main(String[] args) throws InterruptedException {
        new Thread() {

            @Override
            public void run() {
                try {
                    for (int i = 1; i < 21; i += 2) {
                        System.out.println(i + Thread.currentThread().getName());
                        barrier.await();
                    }
                } catch (BrokenBarrierException e) {
                    //do something
                } catch (InterruptedException e) {
                    //do something
                }
            }
        }.start();
        new Thread() {

            @Override
            public void run() {
                try {
                    for (int i = 2; i < 21; i += 2) {
                        barrier.await();
                        System.out.println(i + Thread.currentThread().getName());
                    }
                } catch (BrokenBarrierException e) {
                    //do something
                } catch (InterruptedException e) {
                    //do something
                }
            }
        }.start();
    }
}
    • Dies wird nicht kontrollieren, wer zuerst ausgeführt wird, nur macht Sie sicher, dass beide threads drucken, die erste Zahl vor dem drucken einer zweiten Zahl.
    InformationsquelleAutor assylias
Schreibe einen Kommentar