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);
}
}
}
}
你这只是加了if判断的标记，跟多线程的锁没关系，你把锁的概念理解错啦，还有 if (resource.flag==true)直接 if (resource.flag)这样写就可以，多看看书。
你这程序太乱，看不懂。写个线程有这么复杂吗
用锁旗标控制死锁问题啊，这个自己研究去。可以加我qq,9215695
while (true) 两个死循环，你机器吃得消吗。
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;
// }
}
}
}
休眠了一毫秒,程序就能正常运行了,这是为什么..........................@
休眠了一毫秒,程序就能正常运行了,这是为什么..........................@
休眠了一毫秒,程序就能正常运行了,这是为什么..........................@
同步操作使用锁不当，才会产生死锁问题。你这段代码没有同步操作，当然不会有死锁问题 。但是会有数据不一致问题。
你这段代码，生产者线程和消费者线程共享了Resource这个对象，所以对这个对象访问时需要作同步处理，才能保证数据的一致性。即你的Resource类的方法需要用同步处理。
你的代码就是休眠一秒，继续执行的啊，根本没有锁竞争问题。
1.没死锁，是被你自己的代码轮死的。两个while(true)直接把cpu耗尽了.中间加个Thread.sleep(100)看看
2.Resource.flag需要设置成volatile,否则线程不可见。或则使用AtomicBoolean也行。