HardBirch

java多线程通信

时间:09-08-20 栏目:iOS移动应用开发技术 作者:张飞不张,文采横飞 评论:1 点击: 1,636 次

java多线程通信,模拟生产者-消费者关系。

1种实现(该实现存在问题),具体代码如下:

 

/**
* 模拟生产者-消费者关系
* @author 张燕广
*
*/
public class ThreadCommunication {
public static void main(String[] args) {
Warehouse w = new Warehouse();
Proudcer p = new Proudcer(w);
Consumer c = new Consumer(w);
p.start();
c.start();
}
}

/**
* 生产者
* @author 张燕广
*
*/
class Proudcer extends Thread {
Warehouse w;

Proudcer(Warehouse w) {
this.w = w;
}

@Override
public void run() {
for (int i = 1; i <= 10; i++) {
// 生产商品
w.put(i);
//该语句引起问题
System.out.println("Producer 生产 " + i);
}
}
}

/**
* 消费者
* @author 张燕广
*
*/
class Consumer extends Thread {
Warehouse w;

Consumer(Warehouse w) {
this.w = w;
}

@Override
public void run() {
while (true) {
//该语句引起问题
System.out.println("Customer "+" 消费 "+ w.get());
}
}
}

/**
* 仓库
* @author 张燕广
*
*/
class Warehouse {
private int value;
boolean bFull = false; //仓库是否有商品
// 生产商品
public synchronized void put(int value) {
if (!this.bFull) { // 仓库中没有商品
this.value = value;
this.bFull = true;
this.notify(); // 通知消费者进行消费
}
try {
this.wait(); // 等待消费者消费商品
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}

}

// 消费商品
public synchronized int get() {
if (!this.bFull) { //仓库中没有商品
try {
this.wait(); //等待生产者生产商品
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
this.bFull = false;
this.notify(); //通知生产者生产商品
return this.value;
}
}

虽然生产方法put和消费方法get都进行了同步操作,但是执行以上代码,打印的结果却是错误的。原因是Proudcer类中run方法中以下两行代码没有进行同步操作:

    w.put(i);
//
该语句引起问题
System.out.println("Producer
生产 " + i);

   当执行完毕w.put(i);CPU时间片完毕,这时候下面的打印语句还没有执行,所以就出问题了。

 2种实现,修改第1种实现,解决其存在的问题,具体代码如下:

 

/**
* 模拟生产者-消费者关系
* @author 张燕广
*
*/
public class ThreadCommunication {
public static void main(String[] args) {
Warehouse w = new Warehouse();
Proudcer p = new Proudcer(w);
Consumer c = new Consumer(w);
p.start();
c.start();
}
}

/**
* 生产者
* @author 张燕广
*
*/
class Proudcer extends Thread {
Warehouse w;

Proudcer(Warehouse w) {
this.w = w;
}

@Override
public void run() {
for (int i = 1; i <= 10; i++) {
// 生产商品
w.produce(i);
}
}
}

/**
* 消费者
* @author 张燕广
*
*/
class Consumer extends Thread {
Warehouse w;

Consumer(Warehouse w) {
this.w = w;
}

@Override
public void run() {
while (true) {
w.consume();
}
}
}

/**
* 仓库
* @author 张燕广
*
*/
class Warehouse {
private int value;
private boolean bFull = false; //仓库是否有商品
// 生产商品
public synchronized void produce(int newValue) {
if (!this.bFull) { // 仓库中没有商品
this.value = newValue;
System.out.println("Producer:生产 " + newValue);
this.bFull = true;
this.notify(); // 通知消费者进行消费
}
try {
this.wait(); // 等待消费者消费商品
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}

}

// 消费商品
public synchronized void consume() {
if (!this.bFull) { //仓库中没有商品
try {
this.wait(); //等待生产者生产商品
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
this.bFull = false;
this.notify(); //通知生产者生产商品
System.out.println("Customer->消费 " + this.value);
}
}

   该实现虽然没有什么问题,但是其设计并不合理。

3种实现,完善第2种实现,具体代码如下:

/**
* 模拟生产者-消费者关系
* @author 张燕广
*
*/
public class ThreadCommunication {
public static void main(String[] args) {
Warehouse w = new Warehouse();
Proudcer p = new Proudcer(w);
Consumer c = new Consumer(w);
p.start();
c.start();
}
}

/**
* 生产者
* @author 张燕广
*
*/
class Proudcer extends Thread {
Warehouse w;

Proudcer(Warehouse w) {
this.w = w;
}

@Override
public void run() {
for (int i = 1; i <= 10; i++) {
// 生产商品
this.produce(i);
}
}

// 生产商品
public void produce(int value){
synchronized(w){
if (!w.isBFull()) { // 仓库中没有商品
w.setValue(value);
System.out.println("Producer:生产 " + value);
w.setBFull(true);
w.notify(); // 通知消费者进行消费
}
try {
w.wait(); // 等待消费者消费商品
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
}

/**
* 消费者
* @author 张燕广
*
*/
class Consumer extends Thread {
Warehouse w;

Consumer(Warehouse w) {
this.w = w;
}

@Override
public void run() {
while (true) {
this.consume();
}
}

// 消费商品
public void consume(){
synchronized(w){
if (!w.isBFull()) { //仓库中没有商品
try {
w.wait(); //等待生产者生产商品
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
w.setBFull(false);
w.notify(); //通知生产者生产商品
System.out.println("Customer->消费 " + w.getValue());
}
}
}

/**
* 仓库
* @author 张燕广
*
*/
class Warehouse {
private int value;
private boolean bFull = false; //仓库是否有商品

public int getValue() {
return value;
}

public void setValue(int value) {
this.value = value;
}

public boolean isBFull() {
return bFull;
}

public void setBFull(boolean full) {
bFull = full;
}
}

声明: 本文由( 张飞不张,文采横飞 )原创编译,转载请保留链接: java多线程通信

java多线程通信:目前有1 条留言

  1. 沙发
    匿名用户:

    package com.io.test;

    import java.io.BufferedReader;
    import java.io.File;
    import java.io.FileNotFoundException;
    import java.io.FileReader;
    import java.io.FileWriter;
    import java.io.IOException;
    import java.io.InputStreamReader;

    public class IOTest {

    /**
    * @param args
    */
    public static void main(String[] args) {
    //原始字符串文件
    String filePath = &quot;c:/file.txt&quot;;
    //排序后字符串文件
    String sortedFilePath = &quot;c:/io_sort.txt&quot;;
    String split = &quot;#&quot;;
    IOTest iot = new IOTest();

    //输入字符串
    iot.InputChar(filePath,split);

    //文件内容排序
    iot.FileContentSort(filePath, sortedFilePath, split);

    }

    private void printStrArray(String[] strArray){
    int lenth = strArray.length;
    for(int i=0;i&lt;lenth;i++){
    System.out.println(strArray[i]);
    }
    }

    /**
    * 字符串排序方法
    * @param destStrArray
    * @return
    */
    private String[] getSortedContent(String[] destStrArray){
    System.out.println(&quot;排序前字符串:&quot;);
    printStrArray(destStrArray);

    int length = destStrArray.length;

    System.out.println(&quot;length:&quot;+length);

    String tempStr = null;
    for(int i=0;i&lt;length;i++){
    for(int j=i;j&lt;length-i-1;j++){
    if(destStrArray[j].compareToIgnoreCase(destStrArray[j+1])&gt;0){
    tempStr = destStrArray[j];
    destStrArray[j] = destStrArray[j+1];
    destStrArray[j+1] = tempStr;
    System.out.println(&quot;j:&quot;+j);
    }
    }
    }

    System.out.println(&quot;排序后字符串:&quot;);
    printStrArray(destStrArray);

    return destStrAr

    2010-07-12 16:40 [回复]

发表评论


QQ群互动

Linux系统与内核学习群:194051772

WP建站技术学习交流群:194062106

魔豆之路QR

魔豆的Linux内核之路

魔豆的Linux内核之路

优秀工程师当看优秀书籍

优秀程序员,要看优秀书!

赞助商广告

友荐云推荐