1

この問題の解決策を見つけることができません。私はある時点で混乱していますが、わかりません。これを克服するための提案をお願いします。

問題：

3 つの配列があり、各配列はスレッドに割り当てられ、出力は順番に行われる必要があります...

t1 ={1,4,7} t2 ={2,5,8} t3 ={3,6,9}

期待される出力

アウト = {1,2,3,4,5,6,7,8,9}

私が試したもの：

public class Worker extends Thread {
    Worker next;
    int[] val;
    Object lock = new Object();

    Worker(int[] val) {

        this.val = val;
    }

    public void setnext(Worker next) {
        this.next = next;
    }

    @Override
    public void run() {
        for (int i = 0; i < val.length; i++) {
            synchronized (this) {
                synchronized (next) {

                    System.out.println(val[i]);
                    next.notify();

                }

                synchronized (this) {
                    try {

                        this.wait();
                    } catch (InterruptedException e) {
                        // TODO Auto-generated catch block
                        e.printStackTrace();
                    }
                }
            }
            synchronized(next){
                next.notify();
            }
        }
    }
}

とテストクラス

public class TestWorker {
    public static void main(String[] args) throws Exception{
        Worker worker1 = new Worker(new int[]{1,4,7});
        Worker worker2 = new Worker(new int[]{2,5,8});
        Worker worker3 = new Worker(new int[]{3,6,9});

        worker1.setnext(worker3);
        worker2.setnext(worker1);
        worker3.setnext(worker2);

        worker1.start();
        worker2.start();
        worker3.start();

    }
}
4

1 に答える 1

4

私のバージョンを試してください。待機は常にループで使用する必要があることに注意してください。

public class Worker extends Thread {
    int[] val;
    Worker next;
    boolean ready;
    boolean go;

    Worker(int[] val) {
        this.val = val;
    }

    public void setNext(Worker next) {
        this.next = next;
    }

    @Override
    public void run() {
        synchronized (Worker.class) {
            ready = true;
            Worker.class.notifyAll();
            for (int i = 0; i < val.length; i++) {
                try {
                    while (!go) {
                        Worker.class.wait();
                    }
                    System.out.println(val[i]);
                    go = false;
                    next.go = true;
                    Worker.class.notifyAll();
                } catch (InterruptedException e) {
                }
            }
        }
    }

    public static void main(String[] args) throws Exception {
        Worker worker1 = new Worker(new int[] { 1, 4, 7 });
        Worker worker2 = new Worker(new int[] { 2, 5, 8 });
        Worker worker3 = new Worker(new int[] { 3, 6, 9 });

        worker1.setNext(worker2);
        worker2.setNext(worker3);
        worker3.setNext(worker1);

        worker1.start();
        worker2.start();
        worker3.start();

        synchronized (Worker.class) {
            while(!worker1.ready || !worker2.ready ||!worker3.ready ) {
                Worker.class.wait();
            }
            worker1.go = true;
            Worker.class.notifyAll();
        }
    }
}

出力

1
2
3
4
5
6
7
8
9
于 2013-04-06T06:20:32.973 に答える