количество потоков

[asdas]

Как определить количество запущенных потоков?
нужно чтобы поток не выполнял действия пока есть другие потоки.

У меня в случае если пользователь нажмет быстро на кнопку второй раз запускается тот же процесс  И в критической секции происходит deadlock. И соответственно при входе в критическую секцию в случае если запущено 2 потока второй должен подождать.

[Dimka]

Критическая секция - это по определению участок, который проходит в один момент времени лишь один поток, а все остальные ждут на входе.

Вопрос о количестве запущенных потоков к описанной проблеме не относится. Однако в природе существует такой объект синхронизации, как семафор, который реализует подсчёт пользователей и ограничивает это число. Не уверен, что он есть в Java, но можно и без него обойтись.

Покажи свой код критической секции. Поскольку складывается впечатление, что ты допустил ошибку в её программировании.

[Алексей++]

с помощью критической секции тоже можно организовать семафор

[asdas]

Вообще код достаточно большой, в основном не мной написанный
Нажатие на кнопку долго обрабатывается и если пользователь сразу же нажмет второй раз запускается второй одинаковый процесс.
Как мне можно на несколько секунд приостановить выполнение второго потока перед критической секцией?

[npak]

asdas,

В Java есть пакет java.util.concurrent http://download.oracle.com/javase/6/docs/api/java/util/concurrent/package-summary.html
В этом пакете множество классов, упрощающих разработку многопоточных приложений.

Однакож я не понял одного - что значит "запускается второй одинаковый процесс"? Может быть, речь идет о запуске ещё одного потока?

Как мне можно на несколько секунд приостановить выполнение второго потока перед критической секцией?

Обернуть код критической секции в конструкцию synchronised(lock) { }
где lock - произвольный объект, хоть this.

[Dimka]

asdas, ещё раз повторяю, что при вхождении в критическую секцию, уже занятую одним потоком, все остальные потоки останавливаются автоматически. Ничего для этого делать не надо.

Что действительно надо - так это правильно описать критическую секцию. Поэтому приведи свой код критической секции в точках входа и выхода из неё. Без твоего кода разговор беспредметный - либо ты неправильно понимаешь и описываешь свою ошибку (дело не в критических секциях), либо у тебя неправильно реализована критическая секция.

[asdas]

мда... synchronised(this) уже сделан
Видимо меня переклинило чутка
Здесь просто нажатие очень долго обрабатывается - много методов и если второй раз нажать быстро, то нормальное выполнение приложения заканчивается.
Надо видимо запретить обработку кнопки до завершения первой обработки
как это проще всего сделать?
Здесь все находится в разных классахю

 

Добавлено через 1 час, 40 минут и 8 секунд:
в принципе разобрался
всем спасибо

[Asafj]

А вообще, если система долго обрабатывает нажатие и затем падает при быстро повторном нажатии - такое часто бывает?
И нормальное здесь решение -  сделать переенную public static boolean - чтобы узнавать состояние из другого класса?

[Dimka]

Asafj, сделать флажок - нормально, а почему static?

[RXL]

Думаю, что если внешнее действие в флагом - только чтение, то лучше делать его скрытым и завести метод для его чтения. Надежнее.

[Asafj]

Да. как вариант
спс

[asdas]

А еще по этой теме вопрос:
Как мне здесь лучше прочитать значение флага:
Вот у меня так : while(Update) {a();}
но если Update=false
a() пропускается
Какие здесь есть варианты?
туплю я что-то по-черному..

[RXL]

asdas, а что требуется?

[asdas]

требуется подождать пока Update не станет =true и тогда уже выполнять a()

[RXL]

while (Update);
a();

Только в реальной программе в многозадачной среде такое ожидание не допустимо - в цикл нужно добавить функцию пропуска (что-то типа yeld())

[npak]

asdas,

по хорошему вам нужен примитив синхронизации CountDownLatch

[Asafj]

А чем отличаются записи:
while (Update);
a();

while(Update) {a();}

[npak]

А чем отличаются записи:
while (Update);
a();

while(Update) {a();}

Первый случай эквивалентен такой записи:

Код: (Java)

while(Update) {}
a();

Разница понятна?

[Asafj]

Да, спасибо, разница понятна. В принципе это мне и надо.
Только здесь наверное 
while (!Update);
a();
Вот только из этого метода a() вызывается метод другого класса и создается поток.
Следовательно, в a() что-то типа sleep вызвать нельзя
Или все-таки  {} проканает здесь?

[npak]

Asafj, если вам нужно ждать события, которое произойдет в другом потоке, то while(!Update) - худшее, что можно придумать.

В Java с самого рождения разработан механизм wait - notify. Для отправки сигнала из потока 1 в поток 2 оба потока используют общий объект, я назову его signal (тип Object)
Поток 1, когда ему нужно отправить сигнал, использует такой код:

Код:

synchronized(signal) { signal.notify(); }

Поток 2 ожидает сигнал:

Код:

synchronized(signal) { signal.wait(); }

Недостаток этого решения в том, что второй поток должен вызвать wait до того, как первый отправит notify, в противном случае второй поток будет ждать бесконечно.

Более безопасным в этом смысле является CountDownLatch. Поток, который ждет сигнала, вызвает

Код: (Java)

latch.await();

Поток, который посылает сигнал, делает

Код: (Java)

latch.countDown();

Недостаток этого решения в том, что сигнал можно отправить только один раз.

Наиболее общий способ - воспользоваться синхронизированными контейнерами. Например ArrayBlockingQueue или SynchronousQueue
Поток, который ждет сигнал, вызвает

Код: (Java)

queue.take();

Поток, отправляющий сигнал, вызывает

Код: (Java)

queue.offer(x);