1

Здравствуйте, есть задание создать конвейер, где каждый рабочий это 1 поток. Нужно сделать так чтобы потоки обрабатывали предметы. Написал вот такой код, но он очень не стабильный. Выдает правильный результат через некоторое кол-во запусков. Посоветуйте, что можно сделать (sleep нельзя использовать)

public class Worker extends Thread{
private int id;
private static int itemCounter;
private int current = 1;
private static Worker[] workers;
private boolean done = false;

private Worker(String name, int id) {
    setName(name);
    this.id = id;
}

@Override
public void run() {

    try {

        if (id != 0) {
            synchronized (this) {

                wait();
            }
        }

        while (current <= itemCounter) {
            synchronized (this) {



                System.out.println(Thread.currentThread().getName() + " processing " + current + " item");
                current++;
            }

            if (id < (workers.length - 1)) {
                synchronized (workers[id + 1]) {


                    workers[id + 1].notify();
                }
            }

            if (id > 0) {
                synchronized (workers[id - 1]) {


                    workers[id - 1].notify();
                }
            }



            synchronized (this) {


                if (workers.length != 1) {
                    if (id == (workers.length - 1) && workers[id - 1].done) {
                        continue;
                    }
                    if (current > itemCounter) {
                        done = true;
                        break;
                    }
                    wait();

                }
            }
        }

    } catch (Exception e) {
        e.printStackTrace();
    }
}

public static void main(String[] args) {
    int workerCounter = 0;
    if (args.length != 2) {
        System.err.println("Error, use two arguments!");
        throw new Error();

    } else {
        try {
            workerCounter = Integer.parseInt(args[0]);
            itemCounter = Integer.parseInt(args[1]);
            if (workerCounter <= 0 || itemCounter <= 0) {
                throw new Exception();
            }
        } catch (Exception e) {
            System.err.println("Error: Invalid args.");
            System.exit(1);
        }

        System.out.println(workerCounter + " Workers; " + itemCounter + " Items");

        workers = new Worker[workerCounter];
        for (int i = 0; i < workers.length; i++) {

            workers[i] = new Worker("Worker" + (i + 1), i);
        }

        for (int i = 1; i < workers.length; i++) {

            workers[i].start();
        }
        workers[0].start();
    }
}

}

Результаты

введите сюда описание изображения

1
  • Если инструмент, с помощью которого необходимо решить задачу не критичен, то я бы посоветовал использовать барьеры: docs.oracle.com/javase/7/docs/api/java/util/concurrent/… Они созданы специально для синхронизации между собой потоков. Насчет Вашего кода, мне не совсем понятно решение синхронизироваться по текущему объекту (this) и использование локальной переменной current 12 апр 2018 в 0:57

1 ответ 1

2

Как верно было подмечено выше synchronized (this) в данном случае не имеет смысла, т.к. лок захватывается на экземпляр Worker, который вызвал метод run(). Насколько я понял из задачи, Вам нужно синхронизироваться по полю current.

Но синхронизации в этом случае стоит предпочесть атомики, т.к. они работают гораздо быстрее. В Вашем случае можно использовать AtomicIntegerи его методы: incrementAndGet(), compareAndSet().

Ваш ответ

By clicking “Отправить ответ”, you agree to our terms of service and acknowledge that you have read and understand our privacy policy and code of conduct.

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