0

Здравствуйте, есть два потока. Каждый должен выводить в консоль 10 строк, в каждой строке по 5 символов. Например:

00000
11111
00000
11111

и так далее.

Главное чтобы работало все синхронно. Никак не получается оседлать System.out. Как добиться синхронизации ? Пробовал и метод создавать с модификатором syncronized и join() использовал.

7
  • Что имеете в виду под работало все синхронно? В строке вывода есть информация о том, какой поток выводит? Приведите свой код. 24 ноя 2017 в 20:10
  • Сначала первый поток печает 5 нулей, затем второй печатает 5 единичек и так 20 раз (то есть каждый по 10 строк выводит)
    – ImZ
    24 ноя 2017 в 20:11
  • 1
    используйте wait и notifyAll, синхронизируйтесь по System.out 24 ноя 2017 в 20:20
  • Пытался, все равно не получается, ведь System.out не печатает сразу, а буферизирует данные.
    – ImZ
    24 ноя 2017 в 20:25
  • тогда выкладывайте код, а там уже посмотрим. 24 ноя 2017 в 20:32

1 ответ 1

0
public class Out0000011111 {

//будет хранить какому потоку можно осуществлять вывод
private static AtomicReference<MyThread> link = new AtomicReference<>();

public static void main(String[] args) throws Exception {

    //для одновременного запуска потоков делаем защелку
    CountDownLatch latch = new CountDownLatch(1);

    MyThread thread1 = new MyThread(false, latch);
    MyThread thread2 = new MyThread(true, latch);

    //пусть каждый поток имеет ссылку на другого
    thread1.setOtherThread(thread2);
    thread2.setOtherThread(thread1);

    link.compareAndSet(null, thread1); //инициализация

    thread1.start();
    thread2.start();

    //на всякий случай подождем чтоб оба на защелке зависли
    Thread.sleep(1000);

    //запуск обоих потоков
    latch.countDown();
}


public static class MyThread extends Thread {
    private boolean flag;   //флаг того что именно печатать
    private CountDownLatch latch;
    private MyThread otherThread;

    public MyThread(boolean flag, CountDownLatch latch) {
        this.flag = flag;
        this.latch = latch;
    }

    void setOtherThread(MyThread thread) {
        this.otherThread = thread;
    }

    @Override
    public void run() {
        super.run();
        try {
            //ждем на защелке
            latch.await();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        for (int i = 0; i < 10; i++) {
            //крутимся в цикле пока не сможем напечатать
            while (true) {
                //печатаем только если разрешено
                if (link.get() == MyThread.this) {
                    if (flag) {
                        System.out.println("11111");
                    } else {
                        System.out.println("00000");
                    }
                    link.compareAndSet(this, otherThread);
                    break;
                }
            }
        }
    }
}}

Ваш ответ

Нажимая на кнопку «Отправить ответ», вы соглашаетесь с нашими условиями использования и подтверждаете, что прочитали и поняли наши политику конфиденциальности и нормы поведения.

Всё ещё ищете ответ? Посмотрите другие вопросы с метками или задайте свой вопрос.