提供了编程的基础技术教程

zl程序教程

您现在的位置是：首页 >  后端

当前栏目

基于java中BlockingQueue的使用介绍

JAVA 使用 基于 介绍 BlockingQueue
2023-06-13 09:14:50 时间
     最近在维护一个java工程，在群里面也就聊起来java的优劣！无奈一些Java的终极粉丝，总是号称性能已经不必C++差，并且很多标准类库都是大师级的人写的，如何如何稳定等等。索性就认真研究一番，他们给我的一项说明就是，在线程之间投递消息，用java已经封装好的BlockingQueue，就足够用了。

     既然足够用那就写代码测试喽，简简单单写一个小程序做了一番测试：
复制代码代码如下:

//默认包
importjava.util.concurrent.*;

importbase.MyRunnable;

publicclassTest
{
   publicstaticvoidmain(String[]args)
   {
       BlockingQueue<Integer>queue=newLinkedBlockingQueue<Integer>();
       java.lang.Runnabler=newMyRunnable(queue);
       Threadt=newThread(r);
       t.start();

       while(true)
       {
           try
           {
               while(true)
               {
                   for(inti=0;i<10000;i++)
                   {
                       queue.offer(i);
                   }
               }
           }
           catch(Exceptione)
           {
               e.printStackTrace();
           }
       }
   }
}

 
//需要添加的包
packagebase;

importjava.lang.Runnable;
importjava.util.concurrent.*;
importjava.util.*;

publicclassMyRunnableimplementsRunnable
{
   publicMyRunnable(BlockingQueue<Integer>queue)
   {
       this.queue=queue;
   }
   publicvoidrun()
   {
       Dated=newDate();
       longstarttime=d.getTime();
       System.err.println(starttime);
       intcount=0;
       while(true)
       {
           try
           {
               Integeri=this.queue.poll();
               if(i!=null)
               {
                   count++;
               }
               if(count==100000)
               {
                   Datee=newDate();
                   longendtime=e.getTime();
                   System.err.println(count);
                   System.err.println(endtime);
                   System.err.print(endtime-starttime);
                   break;
               }

           }
           catch(Exceptione)
           {

           }
       }
   }
   privateBlockingQueue<Integer>queue;
}

        传递十万条数据，在我的测试机上面，大概需要50ms左右，倒是还可以！索性就看了一下BlockingQueue的底层实现

 我在上面的测试代码中使用的offer和poll，就看看这两个实现函数吧，首先是offer
复制代码代码如下:

publicEpoll(){
       finalAtomicIntegercount=this.count;
       if(count.get()==0)
           returnnull;
       Ex=null;
       intc=-1;
       finalReentrantLocktakeLock=this.takeLock;
       takeLock.lock();
       try{
           if(count.get()>0){
               x=extract();
               c=count.getAndDecrement();
               if(c>1)
                   notEmpty.signal();
           }
       }finally{
           takeLock.unlock();
       }
       if(c==capacity)
           signalNotFull();
       returnx;
   }

     和一般的同步线程类似，只是多加了一个signal,在学习unix环境高级编程时候，看到条件变量用于线程之间的同步，可以实现线程以竞争的方式实现同步！
poll函数的实现也是类似！
复制代码代码如下:
publicbooleanoffer(Ee){
       if(e==null)thrownewNullPointerException();
       finalAtomicIntegercount=this.count;
       if(count.get()==capacity)
           returnfalse;
       intc=-1;
       finalReentrantLockputLock=this.putLock;
       putLock.lock();
       try{
           if(count.get()<capacity){
               insert(e);
               c=count.getAndIncrement();
               if(c+1<capacity)
                   notFull.signal();
           }
       }finally{
           putLock.unlock();
       }
       if(c==0)
           signalNotEmpty();
       returnc>=0;
   }

相关文章