2 cuilll cuilll 于 2016.03.06 17:00 提问

没有加同步出现了线程死 但是即使不加同步,也不会产生死锁的呀!!! 求大神 3C

package com.thread;

public class ThreadCommunicationDeadLock {

public static void main(String[] args) {


    Resource resource=new Resource();
    Thread t1=new Thread(new Producer(resource));
    Thread t2=new Thread(new CCustomer(resource));

    t1.start();
    t2.start();

}

}

class Resource {
private int count = 0;
private String name = "apple";
boolean flag=false;//flag标记 默认没有生产

public void set() {

        count++;
        System.out.println("producer"+Thread.currentThread().getName() +" ..."+ name + "--" + count);



}

/**
 * @return the flag
 */
public boolean getFlag() {
    return flag;
}

/**
 * @param flag the flag to set
 */
public void setFlag(boolean flag) {
    this.flag = flag;
}

public void out() {
    System.out.println("customer"+Thread.currentThread().getName() +"..."+ name + "--" + count);


}

}

class Producer implements Runnable {

Resource resource = null;

public Producer(Resource resource) {
    this.resource = resource;
}

@Override
public void run() {

    while (true) {



        if (resource.flag==false) {

            resource.set();

            resource.setFlag(true);

        }

    }

}

}

class CCustomer implements Runnable {
Resource resource = null;

public CCustomer(Resource resource) {
    super();
    this.resource = resource;
}

@Override
public void run() {

    while(true)
    {

        if (resource.flag==true) {
                resource.out();
                resource.setFlag(false);

        }
    }

}

}

7个回答

qq_20039385
qq_20039385   2016.03.06 18:39

while (true) 两个死循环,你机器吃得消吗。

cuilll
cuilll 同一时刻,flag标记不是true,就是false 对吧 ,你可以打印这个标记发现, Producer打印出来的都是false 二customer打印出来的都是true
接近 2 年之前 回复
qq_34111510
qq_34111510   2016.03.06 17:15

你这程序太乱,看不懂。写个线程有这么复杂吗

cuilll
cuilll 生产者生产一个,消费者 打印一个(ID)
接近 2 年之前 回复
qq_34111510
qq_34111510   2016.03.06 17:19

用锁旗标控制死锁问题啊,这个自己研究去。可以加我qq,9215695

qq_20039385
qq_20039385   2016.03.06 17:58

你这只是加了if判断的标记,跟多线程的锁没关系,你把锁的概念理解错啦,还有 if (resource.flag==true)直接 if (resource.flag)这样写就可以,多看看书。

cuilll
cuilll   2016.03.06 19:23

package com.thread;

import javax.net.ssl.SSLException;

public class ThreadCommunicationDeadLock {

public static void main(String[] args) {


    Resource resource=new Resource();
    Thread t1=new Thread(new Producer(resource));
    Thread t2=new Thread(new CCustomer(resource));

    t1.start();
    t2.start();

}

}

class Resource {
private int count = 0;
private String name = "apple";
boolean flag=false;//flag标记 默认没有生产

public void set() {

        count++;
        System.out.println("producer"+Thread.currentThread().getName() +" ..."+ name + "--" + count);



}

/**
 * @return the flag
 */
public boolean getFlag() {
    return flag;
}

/**
 * @param flag the flag to set
 */
public void setFlag(boolean flag) {
    this.flag = flag;
}

public void out() {
    System.out.println("customer"+Thread.currentThread().getName() +"..."+ name + "--" + count);


}

}

class Producer implements Runnable {

Resource resource = null;

public Producer(Resource resource) {
    this.resource = resource;
}

@Override
public void run() {

int times=0;
while (true) {

// System.out.println("Producer"+resource.flag);

        try {
            Thread.sleep(1);
        } catch (InterruptedException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }

                if (resource.flag==false) {

                    resource.set();
//              times++;
                    resource.setFlag(true);

                }

// if (times>5) {
//// break;
// }

    }

}

}

class CCustomer implements Runnable {
Resource resource = null;

public CCustomer(Resource resource) {
    super();
    this.resource = resource;
}

int times=0;
public void run() {

    while(true)
    {

// System.out.println("cus"+resource.flag);

        try {
            Thread.sleep(1);
        } catch (InterruptedException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }

                if (resource.flag==true) {
                    resource.out();

// times++;
resource.setFlag(false);

                }

// if (times>5) {
//// break;
// }
}

}

}
休眠了一毫秒,程序就能正常运行了,这是为什么..........................@
休眠了一毫秒,程序就能正常运行了,这是为什么..........................@
休眠了一毫秒,程序就能正常运行了,这是为什么..........................@

wojiushiwo945you
wojiushiwo945you   Ds   Rxr 2016.03.06 22:09

同步操作使用锁不当,才会产生死锁问题。你这段代码没有同步操作,当然不会有死锁问题 。但是会有数据不一致问题。
你这段代码,生产者线程和消费者线程共享了Resource这个对象,所以对这个对象访问时需要作同步处理,才能保证数据的一致性。即你的Resource类的方法需要用同步处理。
你的代码就是休眠一秒,继续执行的啊,根本没有锁竞争问题。

broust
broust   2016.03.07 11:09

1.没死锁,是被你自己的代码轮死的。两个while(true)直接把cpu耗尽了.中间加个Thread.sleep(100)看看
2.Resource.flag需要设置成volatile,否则线程不可见。或则使用AtomicBoolean也行。

Csdn user default icon
上传中...
上传图片
插入图片
准确详细的回答,更有利于被提问者采纳,从而获得C币。复制、灌水、广告等回答会被删除,是时候展现真正的技术了!