VPF::Синхронизация по одному объекту с двух потоков

ktimtsa

Дата 3.8.2011, 11:17 (ссылка)

(нет голосов)

Загрузка ...

Новичок

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

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

Здравствуйте! Вопрос по синхронизации потоков.

Главный поток ожидает сигналы с других двух потоков. Я использую wait()/notify() по некоторому объекту Object some;
Подскажите пожалуйста можно ли при такой логике определять в главном потоке какой именно поток прислал сигнал notify()?

Заранее огромное спасибо.

Пример кода

Главный поток

Код


package javaapplication7;

import java.util.logging.Level;
import java.util.logging.Logger;

public class MainThread extends Thread{
    public void run(){
        Object some = new Object();
        new FirstThread(some);
        new SecondThread(some);
        synchronized(some){
            try {
                some.wait();
            } catch (Exception ex) {
                Logger.getLogger(MainThread.class.getName()).log(Level.SEVERE, null, ex);
            }
        }
        //тут нужно определить какой именно поток отослал сигнал.
    }
    public static void main(String args[]) {
        new MainThread().start();
    }
}

Вызываемые потоки, разница между ними только в интервале времени sleep

Код



package javaapplication7;

import java.util.logging.Level;
import java.util.logging.Logger;

public class FirstThread extends Thread{
    private Object synchObj;
    public FirstThread(Object synch){
        synchObj = synch;
        start();
    }
    public void run(){
         while(true){
            try {
                sleep(1000);
                System.out.println("first thread sent signal.");
                synchronized(synchObj){
                    synchObj.notify();
                }
            } catch (Exception ex) {
                Logger.getLogger(SecondThread.class.getName()).log(Level.SEVERE, null, ex);
            }
        }
    }
}

Код



package javaapplication7;

import java.util.logging.Level;
import java.util.logging.Logger;

public class SecondThread extends Thread{
    private Object synchObj;
    
    public SecondThread(Object synch){
        synchObj = synch;
        start();
    }
    public void run(){
        while(true){
            try {
                sleep(5000);
                System.out.println("second thread sent signal.");
                synchronized(synchObj){
                    synchObj.notify();
                }
            } catch (Exception ex) {
                Logger.getLogger(SecondThread.class.getName()).log(Level.SEVERE, null, ex);
            }
        }
    }
}

Skipy

Дата 3.8.2011, 12:19 (ссылка)

(нет голосов)

Загрузка ...

Опытный

Профиль
Группа: Участник
Сообщений: 487
Регистрация: 24.8.2006
Где: Москва, Россия

Репутация: 6
Всего: 16

Нет, такой функциональности в базе нет. Можно выставлять какой-то флаг.

--------------------

С уважением,
Евгений aka Skipy
www.skipy.ru

ktimtsa

Дата 3.8.2011, 15:52 (ссылка)

(нет голосов)

Загрузка ...

Новичок

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

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

Спасибо. Наверное придется написать специальный класс с возможностью записать в него строку, кто последний его "трогал". И по нему уже синхронизировать.
Еще раз спасибо.

Farmazon

Дата 4.8.2011, 06:45 (ссылка)

(нет голосов)

Загрузка ...

Разработчик

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

Репутация: 1
Всего: 5

Едрён батон, используй Pipe для этой цели. И вместо Notify пихай сообщение с идентификатором потока...

--------------------

Таково моё общее мнение.

0 Пользователей читают эту тему (0 Гостей и 0 Скрытых Пользователей)
0 Пользователей:
« Предыдущая тема \| Java: Общие вопросы \| Следующая тема »