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

@Yarik199 · Регистрация: 01.11.2013

Студворк — интернет-сервис помощи студентам

Добрый вечер,имеется следующий код,который я написал 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();
                }
            }*/
            
        }
        
        
    }
    
}

@turbanoff · 05.12.2016, 16:47

Из кода не понятно почти ничего. Можете приложить полное исходное задание?

@Yarik199 · 06.12.2016, 01:09 **[ТС]**

Сообщение от turbanoff

Из кода не понятно почти ничего. Можете приложить полное исходное задание?

По шестиполосной автостраде едут машины. В каком то моменте имеем сужение до двухполосной(то есть одновременно могут ехать только два два автомобиля). Дополнительно время от времени на автостраде появляется скорая помощь.
Реализуй выше описанную схему по следующим пунктам:
-Автомобили едут по шестиполосной автостраде и через некоторое время доезжают до двухполосной,только два из них могут преодолеть это.
-Если на автостраде появиться скорая помощь,все машины останавливается и ждут пока скорая помощь проедет через автостраду,после машины начинают ехать снова.
Создай 50 потоков машин и усыпи их так чтобы программа была легкой к интерпретации.

Добавлено через 6 минут
Автострады я сделал Семафорами,шестиполосную которая принимает 6 машин,и когда идет сужение они становятся в очередь и попадают на Семафор двухполосной автострады,который имеет 2 места. Это у меня работает,но вот проблема со скорой. Теперь я не понимаю как ее реализовать. Пусть скорая будет потоком демоном. Но как наш этот Демон будет усыплять все остальные потоки ? Или мне просто переписать код и реализовать его по другой схеме,например Локами ?

@turbanoff · 06.12.2016, 14:32

Так, теперь по порядку. Где у вас потоки машин?

Java
1
class Autostrada extends Thread

Почему вдруг автострада стала потоком?

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

Добавлено через 7 минут
Для скорой должен быть отдельный лок (ReentrantReadWriteLock подойдёт).
Когда скорая хочет поехать - она захватывает writeLock, когда машина едет - она захватывает readLock.
Одновременно можно захватить много read локов, но write лок должен быть захвачен только эксклюзивно.

@Yarik199 · 07.12.2016, 00:06 **[ТС]**

Сообщение от turbanoff

Что такое Karetka? Что такое Samochod?

Karetka - скорая,Samochod - автомобиль
спасибо за ответ,а как реализовать тогда очередь,то есть переход с 6 полосной к 2 полосной ?

@turbanoff · 07.12.2016, 00:21

Сообщение от Yarik199

Karetka - скорая,Samochod - автомобиль

Ну и названия у вас)

У вас идея правильная - два семафора, 2-мя и 6-ю permits.
Автомобиль сначала должен получить разрешение у соответствующего семафора, а потом попытаться захватить readLock и только тогда двигаться.
А скорой достаточно будет захватить writeLock

@Yarik199 · 07.12.2016, 00:46 **[ТС]**

Сообщение от turbanoff

Ну и названия у вас)

Сам улыбался первый месяц,как только в Польшу приехал учиться.

Сообщение от turbanoff

Автомобиль сначала должен получить разрешение у соответствующего семафора, а потом попытаться захватить readLock и только тогда двигаться.
А скорой достаточно будет захватить writeLock

Благодарю,теперь все понятно,сейчас попытаюсь реализовать,в случае проблемы еще завтра отпишусь.

Новые блоги и статьи Все статьи Все блоги /
Валидация и контроль данных табличной части документа перед записью Maks 22.04.2026 Алгоритм из решения ниже реализован на примере нетипового документа, разработанного в КА2. Задача: контроль и валидация данных табличной части документа перед записью с учетом регламента компании. . .	Отчёт о затраченных материалах за определенный период с макетом печатной формы Maks 21.04.2026 Отчёт из решения ниже размещён в конфигурации КА2. Задача: разработка отчёта по затраченным материалам за определённый период, с возможностью вывода печатной формы отчёта с шапкой и подвалом. В. . .	Отчёт о спецтехнике находящейся в ремонте Maks 20.04.2026 Отчёт из решения ниже размещен в конфигурации КА2. Задача: отобразить спецтехнику, которая на данный момент находится в ремонте. Есть нетиповой документ "Заявка на ремонт спецтехники" который. . .	Памятка для бота и "визитка" для читателей "Semantic Universe Layer (Слой семантической вселенной)" Hrethgir 19.04.2026 Сгенерировано для краткого описания по случаю сборки и компиляции скелета серверного приложения. И пусть после этого скажут, что статьи сгенерированные AI - туфта и не интересно. И это не реклама -. . .
Запрет удаления строк ТЧ документа при определённом условии Maks 19.04.2026 Алгоритм из решения ниже реализован на примере нетипового документа "Аккумуляторы", разработанного в конфигурации КА2. У данного документа есть ТЧ, в которой в зависимости от прав доступа. . .	Модель заражения группы наркоманов alhaos 17.04.2026 Условия задачи сформулированы тут Суть: - Группа наркоманов из 10 человек. - Только один инфицирован ВИЧ. - Колются одной иглой. - Колются раз в день. - Колются последовательно через. . .	Мысли в слух. Про "навсегда". kumehtar 16.04.2026 Подумалось тут, что наверное очень глупо использовать во всяких своих установках понятие "навсегда". Это очень сильное понятие, и я только начинаю понимать край его смысла, не смотря на то что давно. . .	My Business CRM MaGz GoLd 16.04.2026 Всем привет, недавно возникла потребность создать CRM, для личных нужд. Собственно программа предоставляет из себя базу данных клиентов, в которой можно фиксировать звонки, стадии сделки, а также. . .

@turbanoff 4094 / 3828 / 745 Регистрация: 18.05.2010 Сообщений: 9,331 Записей в блоге: 12
	05.12.2016, 16:47
	Из кода не понятно почти ничего. Можете приложить полное исходное задание? 0

Опции темы

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

Решение