Модераторы: LSD, AntonSaburov
  

Поиск:

Ответ в темуСоздание новой темы Создание опроса
> Thread wait/notify, Нужно приостановить поток. 
:(
    Опции темы
ShurikA
Дата 12.2.2007, 01:59 (ссылка) | (нет голосов) Загрузка ... Загрузка ... Быстрая цитата Цитата


Зануда
***


Профиль
Группа: Завсегдатай
Сообщений: 1364
Регистрация: 29.10.2005
Где: Канада

Репутация: нет
Всего: 3
Код

class A extends Thread{
...
public synchronized void run(){
...
}
...
}

class B extends Thread{
private A pa;
...
public B(A a){
   pa = a;
}
public synchronized void run(){
...
try {
            synchronized (pa) {
                pa.wait();
                ...
                SomeWork();
                ...
                pa.notify();
}
} catch (Exception ex) {
            ex.printStackTrace();
        }
...
}


Короче суть в том что нужно остановить Thread А  чтобы сделать SomeWork(); и потом запустить дальше.

Но увы всё встаёт на pa.wait();...

Это сообщение отредактировал(а) ShurikA - 12.2.2007, 02:00


--------------------
Если долго мучиться, что нибудь получится...
user posted image
PM MAIL WWW ICQ Skype   Вверх
skhilkov
Дата 12.2.2007, 09:49 (ссылка) | (нет голосов) Загрузка ... Загрузка ... Быстрая цитата Цитата


Опытный
**


Профиль
Группа: Участник
Сообщений: 371
Регистрация: 11.4.2006
Где: TOMSK

Репутация: 2
Всего: 7
ShurikA, 
дело в том, что wait(), notify(), notifyAll() - это методы, которые не должны вызываться у потока, они должны вызываться на объекте, являющимся общим для потоков, разделяющих ресурсы. Я тоже сначала не мог понять что к чему, спасибо LSD, объяснил  smile . Вот тут небольшой примерчик, вроде бы то что тебе было нужно
Код

package multithreading;

public class WaitTesting
{

    class A implements Runnable
    {
        Object locker = null;

        public A(Object obj)
        {
            locker = obj;
        }

        public void run()
        {
            while (true)
            {
                synchronized (locker)
                {
                    System.out.println("Thread A is active!");
                    locker.notifyAll();
                }
                try
                {
                    Thread.sleep(100);
                }
                catch (InterruptedException e)
                {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }
            }

        }
    }

    class B implements Runnable
    {
        private A at = null;
        private Object locker = null;

        public B(A thread, Object obj)
        {
            at = thread;
            locker = obj;
        }

        public void run()
        {
            Thread t = new Thread(at);
            t.start();
            while (true)
            {
                for (int i = 0; i < 5; i++)
                {
                    try
                    {
                        Thread.sleep(500);
                    }
                    catch (InterruptedException e)
                    {
                        // TODO Auto-generated catch block
                        e.printStackTrace();
                    }
                    System.out.println("do some job");
                }
                try
                {
                    synchronized (locker)
                    {
                        locker.wait();
                        System.out.println("LOCKER.WAIT CALLED!!!!!!!!");
                        for (int i = 0; i < 5; i++)
                        {
                            try
                            {
                                Thread.sleep(500);
                            }
                            catch (InterruptedException e)
                            {
                                // TODO Auto-generated catch block
                                e.printStackTrace();
                            }
                            System.out.println("do some job without A thread");
                        }
                        System.out.println("Suspend A Thread");
                        locker.notifyAll();
                    }
                }
                catch (Exception e1)
                {
                    // TODO Auto-generated catch block
                    e1.printStackTrace();
                }

            }
        }
    }

    public static void main(String[] args)
    {
        WaitTesting mainClass = new WaitTesting();
        Object l = new Object();
        A threadA = mainClass.new A(l);

        B threadB = mainClass.new B(threadA, l);
        Thread fgThread = new Thread(threadB);
        fgThread.start();
        try
        {
            fgThread.join();
        }
        catch (InterruptedException e)
        {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
    }

}




--------------------
Кто понял жизнь, тот не спешит. 
PM MAIL   Вверх
ShurikA
Дата 12.2.2007, 10:39 (ссылка) | (нет голосов) Загрузка ... Загрузка ... Быстрая цитата Цитата


Зануда
***


Профиль
Группа: Завсегдатай
Сообщений: 1364
Регистрация: 29.10.2005
Где: Канада

Репутация: нет
Всего: 3
Цитата(skhilkov @  12.2.2007,  08:49 Найти цитируемый пост)
которые не должны вызываться у потока, они должны вызываться на объекте

A чем поток не объект?


--------------------
Если долго мучиться, что нибудь получится...
user posted image
PM MAIL WWW ICQ Skype   Вверх
LSD
Дата 12.2.2007, 11:57 (ссылка) | (нет голосов) Загрузка ... Загрузка ... Быстрая цитата Цитата


Leprechaun Software Developer
****


Профиль
Группа: Модератор
Сообщений: 15718
Регистрация: 24.3.2004
Где: Dublin

Репутация: 210
Всего: 538
Так что ты хочешь, ты вызываешь pa.wait() и текущий поток встает (текущий это B), до тех пор пока кто нибудь не вызовет pa.notify().


--------------------
Disclaimer: this post contains explicit depictions of personal opinion. So, if it sounds sarcastic, don't take it seriously. If it sounds dangerous, do not try this at home or at all. And if it offends you, just don't read it.
PM MAIL WWW   Вверх
ShurikA
Дата 12.2.2007, 13:28 (ссылка) | (нет голосов) Загрузка ... Загрузка ... Быстрая цитата Цитата


Зануда
***


Профиль
Группа: Завсегдатай
Сообщений: 1364
Регистрация: 29.10.2005
Где: Канада

Репутация: нет
Всего: 3
LSD, 
Секунду, а это не должно разве остановить процесс pa?


--------------------
Если долго мучиться, что нибудь получится...
user posted image
PM MAIL WWW ICQ Skype   Вверх
LSD
Дата 12.2.2007, 14:47 (ссылка) | (нет голосов) Загрузка ... Загрузка ... Быстрая цитата Цитата


Leprechaun Software Developer
****


Профиль
Группа: Модератор
Сообщений: 15718
Регистрация: 24.3.2004
Где: Dublin

Репутация: 210
Всего: 538
Нет конечно, это останавливает текущий тред. Тебе же уже сказали:
Цитата(skhilkov @  12.2.2007,  09:49 Найти цитируемый пост)
дело в том, что wait(), notify(), notifyAll() - это методы, которые не должны вызываться у потока, они должны вызываться на объекте, являющимся общим для потоков, разделяющих ресурсы.

т.е. в данной ситуации ты используешь Thread как обычный Object.

Почитай FAQ.


--------------------
Disclaimer: this post contains explicit depictions of personal opinion. So, if it sounds sarcastic, don't take it seriously. If it sounds dangerous, do not try this at home or at all. And if it offends you, just don't read it.
PM MAIL WWW   Вверх
ShurikA
Дата 12.2.2007, 14:54 (ссылка) | (нет голосов) Загрузка ... Загрузка ... Быстрая цитата Цитата


Зануда
***


Профиль
Группа: Завсегдатай
Сообщений: 1364
Регистрация: 29.10.2005
Где: Канада

Репутация: нет
Всего: 3
Цитата(LSD @  12.2.2007,  13:47 Найти цитируемый пост)
они должны вызываться на объекте, являющимся общим для потоков, разделяющих ресурсы.

То есть если у меня этот поток бежит в объекте JPanel jp то и останавливать надо jp?


--------------------
Если долго мучиться, что нибудь получится...
user posted image
PM MAIL WWW ICQ Skype   Вверх
LSD
Дата 12.2.2007, 15:02 (ссылка) | (нет голосов) Загрузка ... Загрузка ... Быстрая цитата Цитата


Leprechaun Software Developer
****


Профиль
Группа: Модератор
Сообщений: 15718
Регистрация: 24.3.2004
Где: Dublin

Репутация: 210
Всего: 538
Нет. 
wait() - просто усыпляет текущий поток (именно текущий, т.е. тот в котором выполняется данный код).
notifyAll() - "будит" все потоки которые вызвали wait() на данном объекте


--------------------
Disclaimer: this post contains explicit depictions of personal opinion. So, if it sounds sarcastic, don't take it seriously. If it sounds dangerous, do not try this at home or at all. And if it offends you, just don't read it.
PM MAIL WWW   Вверх
ShurikA
Дата 12.2.2007, 15:35 (ссылка) | (нет голосов) Загрузка ... Загрузка ... Быстрая цитата Цитата


Зануда
***


Профиль
Группа: Завсегдатай
Сообщений: 1364
Регистрация: 29.10.2005
Где: Канада

Репутация: нет
Всего: 3
Из всего что уже сказанно, я могу понять только то что поток может остановить только самого себя.
хотя это уж врядле...

Ладно, спрошу по другому:

Есть список картонок в котором, отдельным потоком (tA), генерируйутся для них превьюшки.
Так же есь ещё один поток (tB) который тоже занимается масштабированием (для других целей).

нужно перед началом отработки tB остановить tА и в конце отработки возобновить.



--------------------
Если долго мучиться, что нибудь получится...
user posted image
PM MAIL WWW ICQ Skype   Вверх
skhilkov
Дата 12.2.2007, 15:43 (ссылка) | (нет голосов) Загрузка ... Загрузка ... Быстрая цитата Цитата


Опытный
**


Профиль
Группа: Участник
Сообщений: 371
Регистрация: 11.4.2006
Где: TOMSK

Репутация: 2
Всего: 7
ShurikA, 
а чем тебе мой пример не подошел? там вроде то что надо....


--------------------
Кто понял жизнь, тот не спешит. 
PM MAIL   Вверх
LSD
Дата 12.2.2007, 15:43 (ссылка) | (нет голосов) Загрузка ... Загрузка ... Быстрая цитата Цитата


Leprechaun Software Developer
****


Профиль
Группа: Модератор
Сообщений: 15718
Регистрация: 24.3.2004
Где: Dublin

Репутация: 210
Всего: 538
Цитата(ShurikA @  12.2.2007,  15:35 Найти цитируемый пост)
Из всего что уже сказанно, я могу понять только то что поток может остановить только самого себя.

Именно!
Максимум, что он может, это дать команду другому потоку остановиться, но тот поток должен сам себя остановить получив команду.

Цитата(ShurikA @  12.2.2007,  15:35 Найти цитируемый пост)
Есть список картонок в котором, отдельным потоком (tA), генерируйутся для них превьюшки.
Так же есь ещё один поток (tB) который тоже занимается масштабированием (для других целей).

нужно перед началом отработки tB остановить tА и в конце отработки возобновить.

Разберись уже с теми примерами, что тебе давали!


--------------------
Disclaimer: this post contains explicit depictions of personal opinion. So, if it sounds sarcastic, don't take it seriously. If it sounds dangerous, do not try this at home or at all. And if it offends you, just don't read it.
PM MAIL WWW   Вверх
  
 Ответ в темуСоздание новой темы Создание опроса
Правила форума "Java"
LSD   AntonSaburov
powerOn   tux
javastic
  • Прежде, чем задать вопрос, прочтите это!
  • Книги по Java собираются здесь.
  • Документация и ресурсы по Java находятся здесь.
  • Используйте теги [code=java][/code] для подсветки кода. Используйтe чекбокс "транслит", если у Вас нет русских шрифтов.
  • Помечайте свой вопрос как решённый, если на него получен ответ. Ссылка "Пометить как решённый" находится над первым постом.
  • Действия модераторов можно обсудить здесь.
  • FAQ раздела лежит здесь.

Если Вам помогли, и атмосфера форума Вам понравилась, то заходите к нам чаще! С уважением, LSD, AntonSaburov, powerOn, tux, javastic.
 
0 Пользователей читают эту тему (0 Гостей и 0 Скрытых Пользователей)
0 Пользователей:
« Предыдущая тема | Java: Общие вопросы | Следующая тема »

Подписаться на тему | Подписка на этот форум | Скачать/Распечатать тему


 




[ Время генерации скрипта: 0.0551 ]   [ Использовано запросов: 22 ]   [ GZIP включён ]


Реклама на сайте     Информационное спонсорство

 
 По вопросам размещения рекламы пишите на vladimir(sobaka)vingrad.ru
Отказ от ответственности     Powered by Invision Power Board(R) 1.3 © 2003  IPS, Inc.