会员可以在此提问,百战程序员老师有问必答
对大家有帮助的问答会被标记为“推荐”
看完课程过来浏览一下别人提的问题,会帮你学得更全面
截止目前,同学们一共提了 132906个问题
JAVA 全系列/第十一阶段:消息中间件与高并发处理/Nginx 8764楼
Python 全系列/第九阶段:Flask百战电商后台系统/Flask百战电商后台项目 8769楼
JAVA 全系列/第四阶段:网页编程和设计/CSS3 8770楼
JAVA 全系列/第十阶段:百战旅游网项目/百战旅游网 8771楼
JAVA 全系列/第四阶段:网页编程和设计/CSS3 8772楼

老师,我的代码运行时,只会出现单线程跑,似乎是出现了死锁的情况,检查不出问题,请老师帮我看看

package 线程冲突3;


public class ProduceTestThread {

    public static void main(String[] args) {

    SyncStack ss=new SyncStack();

    new shengChang(ss).start();

    new xiaoFei(ss).start();

    }

}

/**

 * 馒头类

 */

class manTou{

    private int id;


    public int getId() {

        return id;

    }


    public void setId(int id) {

        this.id = id;

    }

}


/**

 * 缓冲区

 */

class SyncStack{

    //定义放馒头的盒子

    manTou []mtArr=new manTou[10];

    //定义取馒头的盒子

    int index;


    /**

     * 放馒头的方法

     */

    public synchronized void fang(manTou mt){

        while(index==mtArr.length){

            try {

                wait();

             /*   notify();*/

            } catch (InterruptedException e) {

                e.printStackTrace();

            }

        }

        this.notify();

        mtArr[index]=mt;

        index++;

    }

    /**

     * 取馒头的方法

     */

    public synchronized manTou qu(int index){

        /*System.out.println("测试:进去取");*/

        while(index==0){

            try {

                this.wait();


            } catch (InterruptedException e) {

                e.printStackTrace();

            }

        }

        this.notify();

        this.index--;

        return mtArr[this.index];

    }



}


/**

 * 生产者线程

 */

class shengChang extends  Thread{

    private SyncStack ss;

    shengChang(SyncStack ss){

        this.ss=ss;

    }


    @Override

    public void run() {


        for(int i=0;i<10;i++){

             manTou mt=new manTou();

            ss.fang(mt);

            ss.mtArr[i].setId(i+1);

            System.out.println("生产馒头:"+ss.mtArr[i].getId());


        }

        /*System.out.println("共计生产了馒头"+sum+"个");*/


    }

}


/**

 * 消费者线程

 */

class xiaoFei extends  Thread{

    private  SyncStack ss;

    xiaoFei(SyncStack ss){

        this.ss=ss;

    }


    @Override

    public void run() {

        for(int i=0;i<10;i++){

            ss.qu(i);

            System.out.println("消费馒头:"+ss.mtArr[i].getId());

            /*manTou mt = ss.qu(i);

            System.out.println("消费馒头"+mt.getId());*/

        }

    }

}


JAVA 全系列/第二阶段:JAVA 基础深化和提高/多线程技术 8773楼

老师,我的代码运行时只会单线程的跑?好像是出现了死锁的情况,检查不出问题,请老师帮我看看哪里出错了?

package 线程冲突3;


public class ProduceTestThread {

    public static void main(String[] args) {

    SyncStack ss=new SyncStack();

    new shengChang(ss).start();

    new xiaoFei(ss).start();

    }

}

/**

 * 馒头类

 */

class manTou{

    private int id;


    public int getId() {

        return id;

    }


    public void setId(int id) {

        this.id = id;

    }

}


/**

 * 缓冲区

 */

class SyncStack{

    //定义放馒头的盒子

    manTou []mtArr=new manTou[10];

    //定义取馒头的盒子

    int index;


    /**

     * 放馒头的方法

     */

    public synchronized void fang(manTou mt){

        while(index==mtArr.length){

            try {

                wait();

             /*   notify();*/

            } catch (InterruptedException e) {

                e.printStackTrace();

            }

        }

        this.notify();

        mtArr[index]=mt;

        index++;

    }

    /**

     * 取馒头的方法

     */

    public synchronized manTou qu(int index){

        /*System.out.println("测试:进去取");*/

        while(index==0){

            try {

                this.wait();


            } catch (InterruptedException e) {

                e.printStackTrace();

            }

        }

        this.notify();

        this.index--;

        return mtArr[this.index];

    }



}


/**

 * 生产者线程

 */

class shengChang extends  Thread{

    private SyncStack ss;

    shengChang(SyncStack ss){

        this.ss=ss;

    }


    @Override

    public void run() {


        for(int i=0;i<10;i++){

             manTou mt=new manTou();

            ss.fang(mt);

            ss.mtArr[i].setId(i+1);

            System.out.println("生产馒头:"+ss.mtArr[i].getId());


        }

        /*System.out.println("共计生产了馒头"+sum+"个");*/


    }

}


/**

 * 消费者线程

 */

class xiaoFei extends  Thread{

    private  SyncStack ss;

    xiaoFei(SyncStack ss){

        this.ss=ss;

    }


    @Override

    public void run() {

        for(int i=0;i<10;i++){

            ss.qu(i);

            System.out.println("消费馒头:"+ss.mtArr[i].getId());

            /*manTou mt = ss.qu(i);

            System.out.println("消费馒头"+mt.getId());*/

        }

    }

}


JAVA 全系列/第二阶段:JAVA 基础深化和提高/多线程技术 8774楼

package 线程冲突3;


/**

 * 主线程

 */

public class DeadLockThread {

    public static void main(String[] args) {

        new doMarkUp(0,"大丫").start();

        new doMarkUp(0,"二丫").start();

    }

}


/**

 * 镜子类

 */

class mirror{


}


/**

 * 口红类

 */

class  Lipstick{


}


/**

 * 化妆线程

 */

class doMarkUp extends Thread{

    static mirror m=new mirror();

    static Lipstick l=new Lipstick();

    private String girlName;

    private  int flag; //flag=0:拿了口红 flag!=0:拿了镜子


    public doMarkUp(int F, String gN) {

        this.flag=F;

        this.girlName=gN;

    }


    @Override

    public void run() {

        this.markUp();

    }

    public void markUp(){

        if(flag==0){

            synchronized (l){

                System.out.println(this.girlName+"拿了口红");

                try {

                    Thread.sleep(1000);

                } catch (InterruptedException e) {

                    e.printStackTrace();

                }

                synchronized (m){

                    System.out.println(this.girlName+"拿了镜子");

                }

            }

        }else{

            synchronized (m){

                System.out.println(this.girlName+"拿了镜子");

                try {

                    Thread.sleep(1000);

                } catch (InterruptedException e) {

                    e.printStackTrace();

                }

                synchronized (l){

                    System.out.println(this.girlName+"拿了口红");

                }

            }

        }

    }

}

上述是我看完视频后敲的代码,为什么运行不会出现像视频中死锁的情况呢?


JAVA 全系列/第二阶段:JAVA 基础深化和提高/多线程技术 8775楼

课程分类

百战程序员微信公众号

百战程序员微信小程序

©2014-2025百战汇智(北京)科技有限公司 All Rights Reserved 北京亦庄经济开发区科创十四街 赛蒂国际工业园
网站维护:百战汇智(北京)科技有限公司
京公网安备 11011402011233号    京ICP备18060230号-3    营业执照    经营许可证:京B2-20212637