Java学习者论坛

 找回密码
 立即注册

QQ登录

只需一步,快速开始

手机号码,快捷登录

恭喜Java学习者论坛(https://www.javaxxz.com)已经为数万Java学习者服务超过8年了!积累会员资料超过10000G+
成为本站VIP会员,下载本站10000G+会员资源,购买链接:点击进入购买VIP会员
JAVA高级面试进阶视频教程Java架构师系统进阶VIP课程

分布式高可用全栈开发微服务教程

Go语言视频零基础入门到精通

Java架构师3期(课件+源码)

Java开发全终端实战租房项目视频教程

SpringBoot2.X入门到高级使用教程

大数据培训第六期全套视频教程

深度学习(CNN RNN GAN)算法原理

Java亿级流量电商系统视频教程

互联网架构师视频教程

年薪50万Spark2.0从入门到精通

年薪50万!人工智能学习路线教程

年薪50万!大数据从入门到精通学习路线年薪50万!机器学习入门到精通视频教程
仿小米商城类app和小程序视频教程深度学习数据分析基础到实战最新黑马javaEE2.1就业课程从 0到JVM实战高手教程 MySQL入门到精通教程
查看: 407|回复: 0

[算法学习]先进先出的队列

[复制链接]
  • TA的每日心情
    开心
    2021-3-12 23:18
  • 签到天数: 2 天

    [LV.1]初来乍到

    发表于 2014-11-1 00:00:28 | 显示全部楼层 |阅读模式
    public class SimpleObjectFIFO extends Object {
      

      
         private Object[] queue;   
          private int capacity;//队列容量
             private int size;//队列的大小
             private int head;//队列的当前项
             private int tail;//下一个添加项的索引

             public SimpleObjectFIFO(int cap) {
                     capacity = ( cap > 0 ) ? cap : 1; // at least 1
                     queue = new Object[capacity];
                     head = 0;
                     tail = 0;
                     size = 0;
             }

             public synchronized int getSize() {
                     return size;
             }

             public synchronized boolean isFull() {
                     return ( size == capacity );
             }
      
      
       
       
         
       

       
       
      

          
             public synchronized void add(Object obj) throws InterruptedException {
                     while ( isFull() ) {
                wait();
                     }

                     queue[head] = obj;
                     head = ( head + 1 ) % capacity;
                     size++;

                     notifyAll(); // let any waiting threads know about change
             }

             public synchronized Object remove() throws InterruptedException {
                     while ( size == 0 ) {
                           wait();
                     }

                     Object obj = queue[tail];
                     queue[tail] = null; // don"t block GC by keeping unnecessary reference
                     tail = ( tail + 1 ) % capacity;
                     size--;
                     notifyAll(); // let any waiting threads know about change
                     return obj;
             }

             public synchronized void printState() {
                     StringBuffer sb = new StringBuffer();
                     sb.append("SimpleObjectFIFO:
    ");
                     sb.append("       capacity=" + capacity + "
    ");
                     sb.append("           size=" + size);
                     if ( isFull() ) {
                         sb.append(" - FULL");
                     } else if ( size == 0 ) {
                         sb.append(" - EMPTY");
                     }
                     sb.append("
    ");
                     sb.append("           head=" + head + "
    ");
                     sb.append("           tail=" + tail + "
    ");
                     for ( int i = 0; i < queue.length; i++ ) {
                          sb.append("       queue[" + i + "]=" + queue + "
    ");
                     }

                     System.out.print(sb);
           }
    }
    测试代码:
    public class SimpleObjectFIFOTest extends Object {
            public static void main(String[] args) {
                    try {
                             SimpleObjectFIFO fifo = new SimpleObjectFIFO(5);
                             fifo.printState();
                             fifo.add("S01");
                             fifo.printState();
                             fifo.add("S02");
                             fifo.printState();

                             fifo.add("S03");
                             fifo.printState();
                             Object obj = fifo.remove();
                             System.out.println("just removed obj=" + obj);
                             fifo.printState();
                             fifo.add("S04");
                             fifo.printState();

                             fifo.add("S05");
                             fifo.printState();
                             fifo.add("S06");
                             fifo.printState();
                     } catch ( InterruptedException x ) {
                             x.printStackTrace();
                     }
                     }
    }

    程序运行结果:


    C:java>java SimpleObjectFIFOTest
    SimpleObjectFIFO:
    capacity=5
    size=0 - EMPTY
    head=0
    tail=0
    queue[0]=null
    queue[1]=null
    queue[2]=null
    queue[3]=null
    queue[4]=null
    SimpleObjectFIFO:
    capacity=5
    size=1
    head=1
    tail=0
    queue[0]=S01
    queue[1]=null
    queue[2]=null
    queue[3]=null
    queue[4]=null
    SimpleObjectFIFO:
    capacity=5
    size=2
    head=2
    tail=0
    queue[0]=S01
    queue[1]=S02
    queue[2]=null
    queue[3]=null
    queue[4]=null
    SimpleObjectFIFO:
    capacity=5
    size=3
    head=3
    tail=0
    queue[0]=S01
    queue[1]=S02
    queue[2]=S03
    queue[3]=null
    queue[4]=null
    just removed obj=S01
    SimpleObjectFIFO:
    capacity=5
    size=2
    head=3
    tail=1
    queue[0]=null
    queue[1]=S02
    queue[2]=S03
    queue[3]=null
    queue[4]=null
    SimpleObjectFIFO:
    capacity=5
    size=3
    head=4
    tail=1
    queue[0]=null
    queue[1]=S02
    queue[2]=S03
    queue[3]=S04
    queue[4]=null
    SimpleObjectFIFO:
    capacity=5
    size=4
    head=0
    tail=1
    queue[0]=null
    queue[1]=S02
    queue[2]=S03
    queue[3]=S04
    queue[4]=S05
    SimpleObjectFIFO:
    capacity=5
    size=5 - FULL
    head=1
    tail=1
    queue[0]=S06
    queue[1]=S02
    queue[2]=S03
    queue[3]=S04
    queue[4]=S05 C:java>  
      

      



                            function TempSave(ElementID)
                            {
                                    CommentsPersistDiv.setAttribute("CommentContent",document.getElementById(ElementID).value);
                                    CommentsPersistDiv.save("CommentXMLStore");
                            }
                            function Restore(ElementID)
                            {
                                    CommentsPersistDiv.load("CommentXMLStore");
                                    document.getElementById(ElementID).value=CommentsPersistDiv.getAttribute("CommentContent");
                            }
    回复

    使用道具 举报

    您需要登录后才可以回帖 登录 | 立即注册

    本版积分规则

    QQ|手机版|Java学习者论坛 ( 声明:本站资料整理自互联网,用于Java学习者交流学习使用,对资料版权不负任何法律责任,若有侵权请及时联系客服屏蔽删除 )

    GMT+8, 2025-2-25 17:06 , Processed in 0.364052 second(s), 46 queries .

    Powered by Discuz! X3.4

    © 2001-2017 Comsenz Inc.

    快速回复 返回顶部 返回列表