warace 2011-11-11 15:27
浏览 262
已采纳

问个多线程的问题

http://www.iteye.com/topic/44432

[code="java"]private Queue receivedData = new ArrayBlockingQueue(100);

public void receive(byte[] data, int length) {
    byte [] ldata = new byte[data.length+1];
    System.arraycopy(data, 0, ldata, 0, data.length);
    ldata[data.length]=(byte) length;
    this.receivedData.add(ldata);   

    synchronized(receivedData){                 
        this.receivedData.notify(); 
    }                       

}

private class HandlingThread implements Runnable{

    public void run() {     
        while(true){                
                if(!receivedData.isEmpty()){
                    byte[] data = receivedData.remove();                        
                    dealReceiveData(data);                  
                }                       
                else{
                    try {
                        synchronized(receivedData){
                            receivedData.wait();
                        }

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

                    }
                }

        }
    }   

}[/code]

用的blockingqueue 但是我想当队列空的时候wait 怎么操作呢
这里回复都没解决问题

  • 写回答

4条回答 默认 最新

  • _1_1_7_ 2011-11-11 17:09
    关注

    不需要处理,ArrayBlockingQueue自动阻塞

    [quote]这是一个典型的“有界缓存区”,固定大小的数组在其中保持生产者插入的元素和使用者提取的元素。一旦创建了这样的缓存区,就不能再增加其容量。试图向已满队列中放入元素会导致放入操作受阻塞;试图从空队列中检索元素将导致类似阻塞。[/quote]

    本回答被题主选为最佳回答 , 对您是否有帮助呢?
    评论
查看更多回答(3条)

报告相同问题?

悬赏问题

  • ¥15 微信小程序协议怎么写
  • ¥15 c语言怎么用printf(“\b \b”)与getch()实现黑框里写入与删除?
  • ¥20 怎么用dlib库的算法识别小麦病虫害
  • ¥15 华为ensp模拟器中S5700交换机在配置过程中老是反复重启
  • ¥15 java写代码遇到问题,求帮助
  • ¥15 uniapp uview http 如何实现统一的请求异常信息提示?
  • ¥15 有了解d3和topogram.js库的吗?有偿请教
  • ¥100 任意维数的K均值聚类
  • ¥15 stamps做sbas-insar,时序沉降图怎么画
  • ¥15 买了个传感器,根据商家发的代码和步骤使用但是代码报错了不会改,有没有人可以看看