Java Thread Wait-Notify

Question

У меня есть 3 потока (A, B, C), которые я просто не могу заставить их работать, как я их хочу. ВСЕ эти 3 потока имеют ссылку на один и тот же объект - K. То, что я пытаюсь сделать, - это запустить все 3, а затем в некоторый момент времени, когда поток А попадает в определенное состояние, приостанавливает потоки B и C, пока не выполняет какой-то метод работы(), а когда работа заканчивается, резюме B и C.

Теперь то, что я в моем коде: Thread а имеет ссылку на как B и C. B и C есть метод pause() {synchronized (K) {k.wait; }} Когда A прибывает в определенном состоянии, я вызываю метод run() FROM A: B.pause(), C.pause(). Теперь то, что я ожидаю, это то, что Threads B и C будут waiT до тех пор, пока кто-то не сделает: k.notifyAll(), НО вместо Thread A остановится. Это нормально в java?

Код:

class A implements Runnable { 
    private K k; 
    private B b; 
    private C c; 

    void run() { 
     while(something) { 
     //do something 
     b.pause(); 
     c.pause(); 
      // !!! here this thread will freeze and doSomething2 wont get executed. 
      // what i want is to pause B, C, doSomething2 to get executed and then resume B and C 
     //do something2 
     synchronized(k) { 
      k.notifyAll(); 
     } 
     } 
    } 
} 
class B implements Runnable { 
    private K k; 


    void run() { 
     while(something) { 
     //dome something 
     } 
     } 
    } 
    public pause() { 
     synchronized(k) { k.wait();} 
    } 
} 
class C implements Runnable { 
    private K k; 


    void run() { 
     while(something) { 
     //dome something 
     } 
     } 
    } 
    public pause() { 
     synchronized(k) { k.wait();} 
    } 
} 

Answer 1

Когда вы вызываете B.pause(), он выполняется в локальном потоке, а не в потоке, где вы вызываете метод run B. Для этого существуют некоторые устаревшие методы в классе Thread, но они опасны , см. здесь: http://download.oracle.com/javase/1.5.0/docs/guide/misc/threadPrimitiveDeprecation.html

Answer 2

Вы уверены, что вы называете b.pause(), но объявить B.sleep()?

Было бы неплохо увидеть конструкцию резьбы/код запуска.

Answer 3

Для реализации этого параметра вы можете использовать CylcicBarrier.

CyclicBarrier barrier = new CyclicBarrier(); 

public void run() { 
    new Thread(new A(barrier)).start(); 
    new Thread(new B(barrier)).start(); 

    barrier.await(); // Waits until all threads have called await() 

    // Do something 
} 

public void A implements Runnable { 
    private CyclicBarrier barrier; 

    public A(CyclicBarrier barrier) { 
     this.barrier = barrier; 
    } 

    public void run() { 
     barrier.await(); 
     // Do something. 
    } 
} 

public void B implements Runnable { 
    private CyclicBarrier barrier; 

    public B(CyclicBarrier barrier) { 
     this.barrier = barrier; 
    } 

    public void run() { 
     barrier.await(); 
     // Do something. 
    } 
} 

Answer 4

Вы знаете, что используете 3 разных предмета (мониторы) A.k, B.k, C.k?

Итак, когда B «приостановил», он синхронизируется на собственном мониторе (B.k), который должен быть свободен в любом случае. Ваши потоки не «общаются» каким-либо образом.

Answer 5

Удалите звонки b.pause() и c.pause() от A.run() и позвоните им по их собственным методам запуска.

Answer 6

Если я не понимаю ваше домашнее задание, я думаю, вам нужно научиться прерывать поток. B и C - прерывистые потоки, которые должны обрабатывать прерывание таким образом, чтобы они не возобновлялись, пока им не сказали, что это нормально. Это может выглядеть примерно так:

while(true) 
{ 
    try 
    { 
     Thread.sleep(100); 
     System.out.println("Thread is working normally..."); 
    } 
    catch(InterruptedException e) 
    { 
     System.out.println("Thread has been interrupted, will wait till A is done..."); 
     try 
     { 
     synchronized(monitor) 
     { 
      monitor.wait(); 
     } 
     } 
     catch(InterruptedException e2) 
     { 
     // whatever... 
     } 
    } 
} 

Так что объект, работающий в своем потоке, будет иметь ссылки на два других потока. Объект A будет иметь доступ к общему объекту монитора, к которому также имеют доступ исполняемые файлы в двух других потоках (я назвал его monitor). Когда A прерывает другие потоки, их runnables затем вызывает wait() на мониторе. Когда A будет выполнен, он вызовет notifyAll() на мониторе.ПРИМЕЧАНИЕ. Вы должны также очистить флаг прерывания в других потоках, но я оставляю это для вас, чтобы выяснить - его легко :)

Answer 7

Обычно я не помогаю с домашней работой в этой детали, но я думаю, что вы используете неправильный подход в любом случае, так что я не вижу вреда, помогая вам сделать то, что вы почти наверняка не должны делать :)

class A implements Runnable { 
    private K k; 
    private B b; 
    private C c; 

    void run() { 
     while(something) { 
     //do something 
     b.pause(); 
     c.pause(); 
      // !!! here this thread will freeze and doSomething2 wont get executed. 
      // what i want is to pause B, C, doSomething2 to get executed and then resume B and C 
     //do something2 
     synchronized(k) { 
      k.notifyAll(); 
     } 
     } 
    } 
} 
class B implements Runnable { 
    private K k; 
    volatile boolean isPaused = false; 


    void run() { 
     while(something) { 
     if (isPaused) { 
      synchronized(k) { k.wait();} 
      isPaused = false; 
     } 
     //dome something 
     } 
    } 
    public pause() { 
    isPaused = true; 
    } 
} 
class C implements Runnable { 
    private K k; 
    volatile boolean isPaused = false; 


    void run() { 
     while(something) { 
     if (isPaused) { 
      synchronized(k) { 
      k.wait(); 
      } 
      isPaused = false; 
     } 
     //dome something 
     } 
    } 
    public pause() { 
    isPaused = true; 
    } 
} 

Я предполагаю, что вы действительно хотите сделать, хотя безусловно ожидание вызова in in k in B и C и затем всегда звоните уведомите обо всем A