Форум программистов, компьютерный форум, киберфорум
Java SE (J2SE)
Войти
Регистрация
Восстановить пароль
Блоги Сообщество Поиск Заказать работу  
 
Рейтинг 4.92/13: Рейтинг темы: голосов - 13, средняя оценка - 4.92
2 / 2 / 2
Регистрация: 01.11.2013
Сообщений: 154

Приостановить выполнение потоков

05.12.2016, 02:27. Показов 2898. Ответов 6
Метки нет (Все метки)

Студворк — интернет-сервис помощи студентам
Добрый вечер,имеется следующий код,который я написал 20 минут назад. Один пункт не могу выполнить,мне нужно усыпить все потоки машин когда на автостраде стартанет поток скорой помощи,который должен в задании стартовать каждые 10 сек и усыплять наши потоки машин.Пробовал демоном как то сделать и локом,но бесполезно,машины игнорируют скорую помощь и едут дальше не останавливаясь. Можно ли это сделать каким то способом,даже если в задании я использовал семафоры ? Или при таком раскладе я должен полностью переписать код и использовать другой метод(без семафоров) чтобы как то попытаться усыпить все потоки?

Java
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
import java.util.concurrent.Semaphore;
import java.util.concurrent.locks.*;
 
class Karetka extends Thread{
    public static boolean warunek; 
    public Karetka(){
        setDaemon(true);
        warunek = false;
    }
    public void run(){
        while(true){
            try{
                warunek = true;
                sleep(10000);
                warunek = false;
                sleep(5000);
            }catch(InterruptedException e){
                System.out.println("Blad: " + e.toString());
            }
        }
    }
    
}
 
class Samochod{
    
    private String name;
    public Samochod(String name){
        this.name = name;
    }
    public String getName(){
        return name;
    }
    
}
 
 
class Autostrada extends Thread{
    
    
    private static Semaphore autostradaSzescioPasmowa = new Semaphore(6,true);
    private static Semaphore autostradaDwuPasmowa = new Semaphore(2,true);
    private Samochod samochod;
    private Lock karetka = new ReentrantLock();
    
    public Autostrada(Samochod samochod){
        this.samochod = samochod;
    }
    
    public void run(){
        /*try{
            System.out.println("Karetka!!!!");
            karetka.lock();
            sleep(5000);
        }catch(InterruptedException e){
            System.out.println("Blad: " + e.toString());
        }finally{
            karetka.unlock();
        }*/
        
        if(autostradaSzescioPasmowa.tryAcquire()){
            System.out.println("Miejsce w autostradzie szesciopasmowej zajete przez samochod: " + samochod.getName());
            try{
                sleep(5000);
            }catch(InterruptedException e){
                System.out.println("Blad: " + e.toString());
            }
        }else{
            System.out.println("Czekam w kolejce do autostrady szesciopasmowej: " + samochod.getName());
            try{
                autostradaSzescioPasmowa.acquire();
            }catch(InterruptedException e){
                System.out.println("Blad: " + e.toString());
            }
            System.out.println("Miejsce w autostradzie szesciopasmowej zajete przez samochod: " + samochod.getName());
        }
        try{
            System.out.println("Zblizam sie do autostrady dwupasmowej: " + samochod.getName());
            sleep(5000);
        }catch(InterruptedException e){
            System.out.println("Blad: " + e.toString());
        }finally{
            autostradaSzescioPasmowa.release();
            System.out.println("Wyjezdzam z autostrady szesciopasmowej: " + samochod.getName());
        }
        if(autostradaDwuPasmowa.tryAcquire()){
            System.out.println("Miejsce w autostradzie dwupasmowej zajete przez samochod: " + samochod.getName());
            try{
                sleep(5000);
            }catch(InterruptedException e){
                System.out.println("Blad: " + e.toString());
            }
        }else{
            System.out.println("Czekam w kolejce do autostrady dwupasmowej: " + samochod.getName());
            try{
                autostradaDwuPasmowa.acquire();
            }catch(InterruptedException e){
                System.out.println("Blad: " + e.toString());
            }
            System.out.println("Miejsce w autostradzie dwupasmowej zajete przez samochod: " + samochod.getName());
        }
        try{
            System.out.println("Zblizam sie do konca autostrady dwupasmowej: " + samochod.getName());
            sleep(5000);
        }catch(InterruptedException e){
            System.out.println("Blad: " + e.toString());
        }finally{
            autostradaDwuPasmowa.release();
            System.out.println("Wyjezdzam z autostrady dwupasmowej: " + samochod.getName());
        }
        
        
    }
    
    
    
}
 
 
 
 
public class Zadanie2{
    
    
    public static void main(String [] args){
        
        Karetka karetka = new Karetka();
        Thread threadKaretka = new Thread(karetka);
        threadKaretka.start();
        Lock karetkaLock = new ReentrantLock();
        for(int i = 0; i<50; i++){
            try{
                new Autostrada(new Samochod("Audi_" + (i+1))).start();
                Thread.sleep(1000);
            }catch(InterruptedException e){
                System.out.println("Blad: " + e.toString());
            }
            /*if(Karetka.warunek){
                try{
                    karetkaLock.lock();
                    System.out.println("Karetka!!!!");
                }catch(Exception e){
                }finally{
                //  if(!Karetka.warunek) karetkaLock.unlock();
                }
            }*/
            
        }
        
        
    }
    
}
0
Лучшие ответы (1)
IT_Exp
Эксперт
34794 / 4073 / 2104
Регистрация: 17.06.2006
Сообщений: 32,602
Блог
05.12.2016, 02:27
Ответы с готовыми решениями:

Как приостановить выполнение программы в цикле (добавить delay) с помощью таймера?
Добрый вечер. Подскажите, пожалуйста, как приостановить выполнение программы в цикле (добавить delay) с помощью таймера. Например,...

Выполнение нескольких потоков
Объясните каким образом выполняется данный код: class DaughterThread implements Runnable{ String DTname; DaughterThread(String...

Выполнение потоков по очереди
Здравствуйте, изучаю книгу Шилдта и возник вопрос в многопоточности, а именно этот пример: package Synch; class Callme { ...

6
Эксперт Java
 Аватар для turbanoff
4094 / 3828 / 745
Регистрация: 18.05.2010
Сообщений: 9,331
Записей в блоге: 12
05.12.2016, 16:47
Из кода не понятно почти ничего. Можете приложить полное исходное задание?
0
2 / 2 / 2
Регистрация: 01.11.2013
Сообщений: 154
06.12.2016, 01:09  [ТС]
Цитата Сообщение от turbanoff Посмотреть сообщение
Из кода не понятно почти ничего. Можете приложить полное исходное задание?
По шестиполосной автостраде едут машины. В каком то моменте имеем сужение до двухполосной(то есть одновременно могут ехать только два два автомобиля). Дополнительно время от времени на автостраде появляется скорая помощь.
Реализуй выше описанную схему по следующим пунктам:
-Автомобили едут по шестиполосной автостраде и через некоторое время доезжают до двухполосной,только два из них могут преодолеть это.
-Если на автостраде появиться скорая помощь,все машины останавливается и ждут пока скорая помощь проедет через автостраду,после машины начинают ехать снова.
Создай 50 потоков машин и усыпи их так чтобы программа была легкой к интерпретации.

Добавлено через 6 минут
Автострады я сделал Семафорами,шестиполосную которая принимает 6 машин,и когда идет сужение они становятся в очередь и попадают на Семафор двухполосной автострады,который имеет 2 места. Это у меня работает,но вот проблема со скорой. Теперь я не понимаю как ее реализовать. Пусть скорая будет потоком демоном. Но как наш этот Демон будет усыплять все остальные потоки ? Или мне просто переписать код и реализовать его по другой схеме,например Локами ?
0
Эксперт Java
 Аватар для turbanoff
4094 / 3828 / 745
Регистрация: 18.05.2010
Сообщений: 9,331
Записей в блоге: 12
06.12.2016, 14:32
Так, теперь по порядку. Где у вас потоки машин?
Java
1
class Autostrada extends Thread
Почему вдруг автострада стала потоком?

Добавлено через 33 секунды
Что такое Karetka? Что такое Samochod?

Добавлено через 7 минут
Для скорой должен быть отдельный лок (ReentrantReadWriteLock подойдёт).
Когда скорая хочет поехать - она захватывает writeLock, когда машина едет - она захватывает readLock.
Одновременно можно захватить много read локов, но write лок должен быть захвачен только эксклюзивно.
1
2 / 2 / 2
Регистрация: 01.11.2013
Сообщений: 154
07.12.2016, 00:06  [ТС]
Цитата Сообщение от turbanoff Посмотреть сообщение
Что такое Karetka? Что такое Samochod?
Karetka - скорая,Samochod - автомобиль
спасибо за ответ,а как реализовать тогда очередь,то есть переход с 6 полосной к 2 полосной ?
0
Эксперт Java
 Аватар для turbanoff
4094 / 3828 / 745
Регистрация: 18.05.2010
Сообщений: 9,331
Записей в блоге: 12
07.12.2016, 00:21
Лучший ответ Сообщение было отмечено Yarik199 как решение

Решение

Цитата Сообщение от Yarik199 Посмотреть сообщение
Karetka - скорая,Samochod - автомобиль
Ну и названия у вас)

У вас идея правильная - два семафора, 2-мя и 6-ю permits.
Автомобиль сначала должен получить разрешение у соответствующего семафора, а потом попытаться захватить readLock и только тогда двигаться.
А скорой достаточно будет захватить writeLock
0
2 / 2 / 2
Регистрация: 01.11.2013
Сообщений: 154
07.12.2016, 00:46  [ТС]
Цитата Сообщение от turbanoff Посмотреть сообщение
Ну и названия у вас)
Сам улыбался первый месяц,как только в Польшу приехал учиться.
Цитата Сообщение от turbanoff Посмотреть сообщение
Автомобиль сначала должен получить разрешение у соответствующего семафора, а потом попытаться захватить readLock и только тогда двигаться.
А скорой достаточно будет захватить writeLock
Благодарю,теперь все понятно,сейчас попытаюсь реализовать,в случае проблемы еще завтра отпишусь.
0
Надоела реклама? Зарегистрируйтесь и она исчезнет полностью.
BasicMan
Эксперт
29316 / 5623 / 2384
Регистрация: 17.02.2009
Сообщений: 30,364
Блог
07.12.2016, 00:46
Помогаю со студенческими работами здесь

Работа с потоками. Параллельное выполнение потоков
package com.lessons; import java.io.BufferedWriter; import java.io.File; import java.io.FileWriter; import java.io.IOException; ...

Замедление работы потоков если запущено несколько потоков
Есть отдельный поток который движет красным квадратом. Он каждую миллисекунду меняет положение квадрата на пиксель. Есть другой поток, он...

Приостановить выполнения дочернего потока
В классе ChildrenThread нужно реализовать методы для приостановки и продолжения выполнения потока. Приведенный мной пример, очень утрирован...

Приостановить главный поток до закрытия формы
В общем не могу понять, как сделать так, чтоб поток main тормозился, пока не закроется форма public class Client extends JFrame { ...

Приостановить выполнение кода
Здравствуйте. procedure TForm1.Button1Click(Sender: TObject); begin Smothness:=120; MainForm.Timer1.Enabled:= True; ......


Искать еще темы с ответами

Или воспользуйтесь поиском по форуму:
7
Ответ Создать тему
Новые блоги и статьи
SDL3 для Web (WebAssembly): Обработчик клика мыши в браузере ПК и касания экрана в браузере на мобильном устройстве
8Observer8 02.02.2026
Содержание блога Для начала пошагово создадим рабочий пример для подготовки к экспериментам в браузере ПК и в браузере мобильного устройства. Потом напишем обработчик клика мыши и обработчик. . .
Философия технологии
iceja 01.02.2026
На мой взгляд у человека в технических проектах остается роль генерального директора. Все остальное нейронки делают уже лучше человека. Они не могут нести предпринимательские риски, не могут. . .
SDL3 для Web (WebAssembly): Вывод текста со шрифтом TTF с помощью SDL3_ttf
8Observer8 01.02.2026
Содержание блога В этой пошаговой инструкции создадим с нуля веб-приложение, которое выводит текст в окне браузера. Запустим на Android на локальном сервере. Загрузим Release на бесплатный. . .
SDL3 для Web (WebAssembly): Сборка C/C++ проекта из консоли
8Observer8 30.01.2026
Содержание блога Если вы откроете примеры для начинающих на официальном репозитории SDL3 в папке: examples, то вы увидите, что все примеры используют следующие четыре обязательные функции, а. . .
SDL3 для Web (WebAssembly): Установка Emscripten SDK (emsdk) и CMake для сборки C и C++ приложений в Wasm
8Observer8 30.01.2026
Содержание блога Для того чтобы скачать Emscripten SDK (emsdk) необходимо сначало скачать и уставить Git: Install for Windows. Следуйте стандартной процедуре установки Git через установщик. . . .
SDL3 для Android: Подключение Box2D v3, физика и отрисовка коллайдеров
8Observer8 29.01.2026
Содержание блога Box2D - это библиотека для 2D физики для анимаций и игр. С её помощью можно определять были ли коллизии между конкретными объектами. Версия v3 была полностью переписана на Си, в. . .
Инструменты COM: Сохранение данный из VARIANT в файл и загрузка из файла в VARIANT
bedvit 28.01.2026
Сохранение базовых типов COM и массивов (одномерных или двухмерных) любой вложенности (деревья) в файл, с возможностью выбора алгоритмов сжатия и шифрования. Часть библиотеки BedvitCOM Использованы. . .
SDL3 для Android: Загрузка PNG с альфа-каналом с помощью SDL_LoadPNG (без SDL3_image)
8Observer8 28.01.2026
Содержание блога SDL3 имеет собственные средства для загрузки и отображения PNG-файлов с альфа-каналом и базовой работы с ними. В этой инструкции используется функция SDL_LoadPNG(), которая. . .
КиберФорум - форум программистов, компьютерный форум, программирование
Powered by vBulletin
Copyright ©2000 - 2026, CyberForum.ru