Как суммировать вывод двух потоков?

Question

[barabash2090]

Добрый день! Два потока выводят числа от 1 до 10. Задача суммировать числа которые выводятся с первого потока, с теми которые выводятся со второго потока. и вывести соответственно: 2, 4, 6, 8, 10 и т.д.

public class Example {
    public static void main(String[] args) throws InterruptedException {
        Counter counter = new Counter();

        CounterThread ct1 = new CounterThread(counter);
        ct1.start();

        CounterThread ct2 = new CounterThread(counter);
        ct2.start();

        Thread.sleep(1000);
    }
}

class Counter {
    private long counter = 0L;


    public void increaseCounter1() {
        counter++;

    }

    public long getCounter() {
        return counter;
    }
}

class CounterThread extends Thread
{
    private Counter counter;

    public CounterThread(Counter counter) {
        this.counter = counter;
    }

    @Override
    public void run() {
        for(int i=0; i<10; i++) {
            counter.increaseCounter1();
            System.out.println("Thread#1 " + i);
        }
    }
}

Comments

[сергей кузьмин]

это случаем не про стримы вопросец ?

Answer 1

[Михаил]

Так как написано у вас - никак. Потоки сами вызывают println, то есть выводят на экран. И ничего вы с этим не сделаете. Нужно сделать так, чтобы потоки обменивались данными с другим (главным) потоком, который уже будет выполнять обработку данных и выводить на экран. Например через очереди.

import java.util.Queue;
import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.BlockingQueue;
 
public class Main {
 
    static class Task extends Thread {
 
        private final Queue<Integer> queue;
 
        public Task(Queue<Integer> queue) {
            this.queue = queue;
        }
 
        @Override
        public void run() {
            for (int i=0; i<=10; ++i) {
                queue.add(i);
                try {
                    Thread.sleep(100);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        }
    }
 
    public static void main(String[] args) throws InterruptedException {
        final BlockingQueue<Integer> queue1 = new ArrayBlockingQueue<Integer>(100);
        final BlockingQueue<Integer> queue2 = new ArrayBlockingQueue<Integer>(100);
 
        final Thread thread1 = new Task(queue1);
        thread1.start();
        final Thread thread2 = new Task(queue2);
        thread2.start();
 
        while(true) {
            System.out.println(queue1.take() + queue2.take());
        }
 
    }
}

Comments

[barabash2090]

Спасибо! Очень выручили.

Answer 2

[Dmitry Roo]

Как вариант, использовать общую коллекцию, в которую будут стекаться данные из обоих потоков.