Очередь потоков

@leyla89 · Регистрация: 04.08.2013

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

1. Два потока должны выводить по очереди слова из предложения.
2. Алфавит. Один поток выводит на консоль гласные буквы, другой согласные.
Подскажите, пожалуйста, как этого добиться... Вот, что у меня пока что есть:

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
public class ThreadOfWords extends Thread{ 
public ThreadOfWords(String str){ 
super(); 
setName(str); 
}
 
public synchronized void run(){
    String [] mas1 = {"My", "is", "I", "java."};
    String [] mas2 = {"name", "Leyla.", "like", ":)"};
    String [] mas3 = {"a", "e", "i", "o", "u"};
    String [] mas4 = {"b", "c", "d", "f", "g", "h", "j", "k", "l", "m", "n", "p", "q", "r", "s", "t", "v", "w", "x", "y", "z"};
    String nameT = getName();
 
    if("First".equals(nameT)){
        for(int i = 0; i < mas1.length; i++){
            System.out.println(mas1[i]);
            try{
                Thread.sleep(200);
            } catch(InterruptedException e){
                System.out.println(nameT + "прерван");
            }
        }
    } else if("Second".equals(nameT)){
        for(int i = 0; i < mas2.length; i++){
            System.out.println(mas2[i]);
            try{
                Thread.sleep(200);
            } catch(InterruptedException e){
                System.out.println(nameT + "прерван");
            }
        }
    } else if("Third".equals(nameT)){
        for(int i = 0; i < mas3.length; i++){
            System.out.println(mas3[i]);
            try{
                Thread.sleep(500);
            } catch(InterruptedException e){
                System.out.println(nameT + "прерван");
            }
        }
    } else if("Fourth".equals(nameT)){
        for(int i = 0; i < mas4.length; i++){
            System.out.println(mas4[i]);
            try{
                Thread.sleep(500);
            } catch(InterruptedException e){
                System.out.println(nameT + "прерван");
            }
        }
    }       
}
}
 
public class Words { 
public static void main(String[] args) { 
ThreadOfWords tr1 = new ThreadOfWords("First"); 
ThreadOfWords tr2 = new ThreadOfWords("Second");
 
    tr1.setPriority(10);
    tr2.setPriority(1);
 
    tr1.start();
    tr2.start();                
}
}
 
public class ABC { 
public static void main(String[] args) { 
ThreadOfWords tr1 = new ThreadOfWords("Third"); 
ThreadOfWords tr2 = new ThreadOfWords("Fourth");
 
    tr1.setPriority(10);
    tr2.setPriority(1);
 
    tr1.start();
    tr2.start();
}
}

Комментарий модератора

5.16 Запрещено создавать темы с множеством вопросов во всех разделах, кроме разделов платных услуг. Один вопрос - одна тема.

правила форума

@easybudda · 17.10.2013, 09:37

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

Два потока должны выводить по очереди слова из предложения

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
import java.util.Scanner;
 
class WordByWord {
    private boolean oddWord;
    private String [] words;
    private Scanner scan;
    
    WordByWord() {
        scan = new Scanner(System.in);
        
        
        while ( true ) {
            System.out.print("String: ");
            String str = scan.nextLine();
            if ( str.isEmpty() )
                break;
            
            words = str.split(" ");
            oddWord = true;
            
            Thread odds = new Thread(new Runnable() {
                @Override
                public void run() {
                    for ( int i = 0; i < words.length; i += 2 ) {
                        waitMyTurn(true);
                        System.out.println("Odd: " + words[i]);
                        setOddWord(false);
                    }
                }
            });
            
            Thread evens = new Thread(new Runnable() {
                @Override
                public void run() {
                    for ( int i = 1; i < words.length; i += 2 ) {
                        waitMyTurn(false);
                        System.out.println("Even: " + words[i]);
                        setOddWord(true);
                    }
                }
            });
            
            odds.start();
            evens.start();
            try {
                odds.join();
                evens.join();
            }
            catch ( InterruptedException ie ) {
                System.err.println("Interrupted!");
            }
        }
    }
    
    synchronized void waitMyTurn(boolean needOdd) {
        while ( oddWord != needOdd ) {
            try {
                wait();
            }
            catch ( InterruptedException ie ) {}
        }
    }
    
    synchronized void setOddWord(boolean isOdd) {
        oddWord = isOdd;
        notifyAll();
    }
    
    public static void main(String [] args) {
        new WordByWord();
    }
}

@ratcatcher · 17.10.2013, 11:24

Что-то я, по ходу, замудрил

1) поставщик слов:
интерфейс:

Java
1
2
3
4
5
public interface SelectiveStringProvider {
        //отвечает, можно ли забрать слово
    public boolean isAllowed(int writerId);
    public String getString(int writerId);
}

реализация (вариант по словам):

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
public class WordProvider implements SelectiveStringProvider {
    // список слов из фразы
    private LinkedList<String> words;
    
    // идентификатор последнего класса-писателя
    private int lastWriterId;
    
    public WordProvider(String phrase) {
        lastWriterId = 0;
        words = new LinkedList<String>();
        
        StringTokenizer st = new StringTokenizer(phrase);
        while (st.hasMoreTokens()) {
            words.add(st.nextToken());
        }
    }
 
    @Override
    public boolean isAllowed(int writerId) {
        //если разрешение запрашивает писатель с таким же id, 
        //сообщаем, что считывание строки не разрешено
        if (writerId == lastWriterId) {
            return false;
        }
        return true;
    }
 
    @Override
    public String getString(int writerId) {
        //отдавая строку, запоминаем id писателя, которому её отдали
        lastWriterId = writerId;
        return words.pollFirst();
    }

2) Класс-писатель, реализующий Runnable:

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
public class StringWriter implements Runnable {
    private int id;
    private SelectiveStringProvider provider;
    
    public StringWriter(int id, SelectiveStringProvider provider) {
        this.id = id;
        this.provider = provider;
    }
 
    @Override
    public void run() {
        while(true) {
            // получаем монопольный доступ к провайдеру
            synchronized (provider) {
                //спрашиваем, можно ли нам считать строку
                if (provider.isAllowed(id)) {
                    //если можно - считываем
                    String current = provider.getString(id);
                    if (current != null) {
                        //если строка - не null
                        //печатаем, и освобождаем провайдер для другого потока
                        System.out.println(current);
                        //а вот так можно убедиться, что потоки чередуются
                        //System.out.println(current + " " + this.id);
                        provider.notify();
                    } else {
                        //если считали и строка - null
                        //завершаем работу, предварительно уведомив другие потоки
                        // чтобы они так же могли убедиться, что им пора останавливаться
                        provider.notify();
                        break;
                    }
                } else {
                    //если провайдер определил, что нам нельзя получить строку
                    //ждем, пока не уведовят об освобождении провайдера
                    try {
                        provider.wait();
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                }
            }
        }
    }
 
}

3) и для запуска:

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
public class WordsThreadTest {
 
    public static void main(String[] args) {
        WordProvider wordProvider = 
                new WordProvider("Буря мглою небо кроет, вихри снежные крутя");
        
        StringWriter writer1 = new StringWriter(1, wordProvider);
        StringWriter writer2 = new StringWriter(2, wordProvider);
        
        Thread t1 = new Thread(writer1);
        Thread t2 = new Thread(writer2);
        
        t1.start();
        t2.start();
        
        try {
            t1.join();
            t2.join();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
 
}

Новые блоги и статьи Все статьи Все блоги /
Модель здравосоХранения 6. ESG-повестка и устойчивое развитие; углублённый анализ кадрового бренда anaschu 31.03.2026 В прикрепленном документе раздумья о том, как можно поменять модель в будущем	10 пpимет, которые всегда сбываются Maks 31.03.2026 1. Чтобы, наконец, пришла маршрутка, надо закурить. Если сигарета последняя, маршрутка придет еще до второй затяжки даже вопреки расписанию. 2. Нaдоели зима и снег? Не надо переезжать. Достаточно. . .	Перемещение выделенных строк ТЧ из одного документа в другой Maks 31.03.2026 Реализация из решения ниже выполнена на примере нетипового документа "ВыдачаОборудованияНаСпецтехнику" с единственной табличной частью "ОборудованиеИКомплектующие" разработанного в конфигурации КА2. . . .	Functional First Web Framework Suave DevAlt 30.03.2026 Sauve. IO Апнулись до NET10. Из зависимостей один пакет, работает одинаково хорошо как в режиме проекта так и в интерактивном режиме. из сложностей - чисто функциональный подход. Решил. . .
Автоматическое создание документа при проведении другого документа Maks 29.03.2026 Реализация из решения ниже выполнена на нетиповых документах, разработанных в конфигурации КА2. Есть нетиповой документ "ЗаявкаНаРемонтСпецтехники" и нетиповой документ "ПланированиеСпецтехники". В. . .	Настройка движения справочника по регистру сведений Maks 29.03.2026 Решение ниже реализовано на примере нетипового справочника "ТарифыМобильнойСвязи" разработанного в конфигурации КА2, с целью учета корпоративной мобильной связи в коммерческом предприятии. . . .	Автозаполнение реквизита при выборе элемента справочника Maks 27.03.2026 Программный код из решения ниже на примере нетипового документа "ЗаявкаНаРемонтСпецтехники" разработанного в конфигурации КА2. При выборе "Спецтехники" (Тип Справочник. Спецтехника), заполняется. . .	Сумматор с применением элементов трёх состояний. Hrethgir 26.03.2026 Тут. https:/ / fips. ru/ EGD/ ab3c85c8-836d-4866-871b-c2f0c5d77fbc Первый документ красиво выглядит, но без схемы. Это конечно не даёт никаких плюсов автору, но тем не менее. . . всё может быть. . .