主页 / 问题 / 852354
Accepted
Андрей Козицкий
Asked:2020-07-10 02:09:33 +0000 UTC2020-07-10 02:09:33 +0000 UTC

Java线程同步

  • 772

请告诉我我在哪里做错了，我的意思是所有项目的顺序输出，根据数字

public class MainClass {
    public static void main(String[] args) throws InterruptedException {
        ThreadA threadA = new ThreadA();
        ThreadB threadB = new ThreadB();
        threadA.setThreadB(threadB);
        threadB.setThreadA(threadA);

        threadA.start();
        threadB.start();
    }
}

class ThreadA extends Thread{
    private Thread threadB;
    public void setThreadB(ThreadB threadB) {
        this.threadB = threadB;
    }

    @Override
    public void run() {
        synchronized (threadB) {
            try {
                synchronized (this){
                    System.out.println("1.Получили заказ\n");
                    wait();
                    threadB.notify();

                    System.out.println("3.Обдумали план действий\n");
                    wait();
                    threadB.notify();

                    System.out.println("5.Проконтролировали корректное выполнеие\n");
                    wait();
                    threadB.notify();

                    System.out.println("7.Получили деньги\n");
                    wait();
                    threadB.notify();
                }
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }

    }
}

class ThreadB extends Thread{
    private Thread threadA;
    public void setThreadA(ThreadA threadA) {
        this.threadA = threadA;
    }

    @Override
    public void run() {
        synchronized (threadA){
            synchronized (this){
                try {
                    wait();
                    System.out.println("2.Состававили ТЗ\n");
                    threadA.notify();
                    wait();

                    System.out.println("4.Наняли работяг\n");
                    threadA.notify();
                    wait();

                    System.out.println("6.Сдали работу\n");
                    threadA.notify();
                    wait();

                    System.out.println("8.Пошли отмечать\n");
                    threadA.notify();
                }
                catch (InterruptedException e){
                    e.printStackTrace();
                }
            }
        }
    }
}

仅显示以下内容： 1.收到订单

java

1 个回答

  1. Best Answer

    import sun.awt.windows.ThemeReader;

import java.util.Date;
import java.util.Locale;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReadWriteLock;
import java.util.concurrent.locks.ReentrantReadWriteLock;

public class MainClass {
    public static void main(String[] args) throws InterruptedException {
        ForSyncron forSyncron = new ForSyncron();
        forSyncron.setI(0);

        ThreadA threadA = new ThreadA();
        ThreadB threadB = new ThreadB();
        threadA.setForSyncron(forSyncron);
        threadB.setForSyncron(forSyncron);

        threadA.start();
        Thread.sleep(10);
        threadB.start();
    }
}

class ForSyncron{
    private int i;

    public void setI(int i) {
        this.i = i;
    }
    public int getI() {
        return i;
    }
}

class ThreadA extends Thread{
    private ForSyncron forSyncron;
    public void setForSyncron(ForSyncron forSyncron) {
        this.forSyncron = forSyncron;
    }

    @Override
    public void run() {
        try {
            synchronized (forSyncron){
                System.out.println("1.Получили заказ\n");
                forSyncron.wait();

                System.out.println("3.Обдумали план действий\n");
                forSyncron.notify();
                forSyncron.wait();

                System.out.println("5.Проконтролировали корректное выполнеие\n");
                forSyncron.notify();
                forSyncron.wait();

                System.out.println("7.Получили деньги\n");
                forSyncron.notify();
                forSyncron.wait();

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

class ThreadB extends Thread{
    private ForSyncron forSyncron;
    public void setForSyncron(ForSyncron forSyncron) {
        this.forSyncron = forSyncron;
    }


    @Override
    public void run() {
        synchronized (forSyncron){
            try {
                System.out.println("2.Состававили ТЗ\n");
                forSyncron.notify();
                forSyncron.wait();

                System.out.println("4.Наняли работяг\n");
                forSyncron.notify();
                forSyncron.wait();

                System.out.println("6.Сдали работу\n");
                forSyncron.notify();
                forSyncron.wait();

                System.out.println("8.Пошли отмечать\n");
            }
            catch (Exception e){
                e.printStackTrace();
            }
        }
    }

}

//создать связующий объект, + на нем потестить вызов синхрон методов

    • 0

相关问题