草庐IT

队列的模拟及环形队列思路

wyh518 2023-04-17 原文

定义

  • 队列是一个有序列表,可以用数组或是链表来实现。
  • 遵循先入先出的原则。即:先存入队列的数据,要先取出。后存入的要后取出

模拟思路

  • 队列本身是有序列表,若使用数组的结构来存储队列的数据,则队列数组的声明如下图, 其中 maxSize 是该队列的最大容量

  • 因为队列的输出、输入是分别从前后端来处理,因此需要两个变量 front及 rear分别记录队列前后端的下标,front 会随着数据输出而改变,而 rear则是随着数据输入而改变,如图所示

入队出队操作模拟

当我们将数据存入队列时称为”addQueue”,addQueue 的处理需要有两个步骤:

  • 将尾指针往后移:rear+1 , 当 front == rear 时,队列为空

  • 若尾指针 rear 小于队列的最大下标 maxSize-1,则将数据存入 rear所指的数组元素中,否则无法存入数据。rear == maxSize - 1时,队列满

注意:front指向的是队列首元素的前一个位置

实现代码

import java.util.Scanner;
 
public class ArrayQueueDemo {
    public static void main(String[] args) {
        ArrayQueue queue = new ArrayQueue(3);
        Scanner scanner = new Scanner(System.in);
        boolean flag = true;
        while (flag){
            System.out.println("输入a(add)添加数据");
            System.out.println("输入g(get)取出数据");
            System.out.println("输入s(show)显示所有数据");
            System.out.println("输入h(head)显示头部数据");
            System.out.println("输入e(exit)退出程序");
            char c = scanner.next().charAt(0);
            switch (c){
                case 'a':
                    System.out.println("请输入数据");
                    int num = scanner.nextInt();
                    queue.addNum(num);
                    break;
                case 'g':
                    try {
                        queue.getQueue();
                        System.out.println("取出成功");
                    }catch (Exception e){
                        System.out.println(e.getMessage());
                    }
                    break;
                case 's':
                    queue.showQueue();
                    break;
                case 'h':
                    try {
                        queue.headQueue();
                    }catch (Exception e){
                        System.out.println(e.getMessage());
                    }
                    break;
                case 'e':
                    flag = false;
                    System.out.println("程序已退出");
                    break;
                default:
                    break;
            }
        }
        scanner.close();
    }
}
 
class ArrayQueue{
    private int maxSize;//队列的大小
    private int front;//指向队列首元素的前一个位置
    private int rear;//指向队列的尾元素
    private int[] arr;//用数组来实现队列
 
    //构造方法初始化
    public ArrayQueue(int maxSize) {
        this.maxSize = maxSize;
        front = -1;//指向的是队列第一个元素的前一个位置
        rear = -1;
        arr = new int[maxSize];
    }
 
    /**
     * 判断队列是否装满
     * @return
     */
    public boolean isFull(){
        return rear == maxSize-1;
    }
 
    /**
     * 判断队列是否为空
     * @return
     */
    public boolean isEmpty(){
        return front == rear;
    }
 
    /**
     * 为队列添加数据
     * @param num
     */
    public void addNum(int num){
        if (isFull()){
            System.out.println("队列已经满了,无法再加入数据");
            return;
        }
        rear++;
        arr[rear] = num;
    }
 
    /**
     * 取出队列中的数据
     * @return
     */
    public int getQueue(){
        if (isEmpty()){
            throw new RuntimeException("队列为空,不能取出数据");
        }
        front++;
        return arr[front]=0;
    }
 
    /**
     * 显示队列的所有数据
     */
    public void showQueue(){
        if (isEmpty()) {
            System.out.println("队列为空,没有数据");
            return;
        }
        for (int i = 0; i<arr.length; i++){
            System.out.printf("arr[%d]=%d\n",i,arr[i]);
        }
    }
 
    /**
     * 显示队列的头数据,注意不是取出数据
     * @return
     */
    public int headQueue(){
        if (isEmpty()){
            throw new RuntimeException("队列为空,没有数据");
        }
        return arr[front+1];
    }
}

  运行结果

 

 

 

 注意:因先入先出的原则,front和rear最终都会在队列顶部,所以上述队列只能一次性使用,没有达到复用的效果,因此我们要用到环形队列

环形队列

思路:

  • front变量含义调整:front变量指向队首元素,初值为0
  • rear变量含义调整:rear变量指向队尾元素的下一个元素,初值为0。规定空出一个位置
  • 队列为空的判定条件:front == rear
  • 队列为满的判定条件:(rear + 1) % maxSize == front
  • 队列中有效元素的个数:(rear - front + maxSize) % maxSize
  • 入队和出队时,都需要让标记对maxSize取模
  • import java.util.Scanner;
     
    public class CyclicArrayQueueDemo {
        public static void main(String[] args) {
            CyclicArrayQueue queue = new CyclicArrayQueue(3);
            Scanner scanner = new Scanner(System.in);
            boolean flag = true;
            while (flag){
                System.out.println("输入a(add)添加数据");
                System.out.println("输入g(get)取出数据");
                System.out.println("输入s(show)显示所有数据");
                System.out.println("输入h(head)显示头部数据");
                System.out.println("输入e(exit)退出程序");
                char c = scanner.next().charAt(0);
                switch (c){
                    case 'a':
                        System.out.println("请输入数据");
                        int num = scanner.nextInt();
                        queue.addNum(num);
                        break;
                    case 'g':
                        try {
                            int n = queue.getQueue();
                            System.out.println("取出的数是:"+n);
                        }catch (Exception e){
                            System.out.println(e.getMessage());
                        }
                        break;
                    case 's':
                        queue.showQueue();
                        break;
                    case 'h':
                        try {
                            queue.headQueue();
                        }catch (Exception e){
                            System.out.println(e.getMessage());
                        }
                        break;
                    case 'e':
                        flag = false;
                        System.out.println("程序已退出");
                        break;
                    default:
                        break;
                }
            }
            scanner.close();
        }
    }
     
    class CyclicArrayQueue {
        private int maxSize;//队列的大小
        private int front;//front变量指向队首元素,初值为0
        private int rear;//rear变量指向队尾元素的下一个元素,初值为0。规定空出一个位置
        private int[] arr;//用数组来实现队列
     
        public CyclicArrayQueue(int maxSize) {
            this.maxSize = maxSize;
            arr = new int[maxSize];
        }
     
        /**
         * 判断队列是否装满
         *
         * @return
         */
        public boolean isFull() {
            return (rear + 1) % maxSize == front;
        }
     
        /**
         * 判断队列是否为空
         *
         * @return
         */
        public boolean isEmpty() {
            return front == rear;
        }
     
        /**
         * 为队列添加数据
         *
         * @param num
         */
        public void addNum(int num) {
            if (isFull()) {
                System.out.println("队列已经满了,无法再加入数据");
                return;
            }
            arr[rear] = num;
            rear = (rear + 1) % maxSize;
        }
     
        /**
         * 取出队列中的数据
         *
         * @return
         */
        public int getQueue() {
            if (isEmpty()) {
                throw new RuntimeException("队列为空,不能取出数据");
            }
            int value = arr[front];
            front = (front + 1) % maxSize;
            return value;
        }
     
        /**
         * 显示队列的所有数据
         */
        public void showQueue() {
            if (isEmpty()) {
                System.out.println("队列为空,没有数据");
                return;
            }
            for (int i = front; i < front + size(); i++) {
                System.out.printf("arr[%d]=%d\n", i % maxSize, arr[i % maxSize]);
            }
        }
     
        public int size() {
            return (rear + maxSize - front) % maxSize;
        }
     
        /**
         * 显示队列的头数据,注意不是取出数据
         * @return
         */
        public int headQueue(){
            if (isEmpty()){
                throw new RuntimeException("队列为空,没有数据");
            }
            return arr[front];
        }
    }
    

      

有关队列的模拟及环形队列思路的更多相关文章

  1. ruby - 如何模拟 Net::HTTP::Post? - 2

    是的,我知道最好使用webmock,但我想知道如何在RSpec中模拟此方法:defmethod_to_testurl=URI.parseurireq=Net::HTTP::Post.newurl.pathres=Net::HTTP.start(url.host,url.port)do|http|http.requestreq,foo:1endresend这是RSpec:let(:uri){'http://example.com'}specify'HTTPcall'dohttp=mock:httpNet::HTTP.stub!(:start).and_yieldhttphttp.shou

  2. ruby - 分布式事务和队列,ruby,erlang,scala - 2

    我有一个涉及多台机器、消息队列和事务的问题。因此,例如用户点击网页,点击将消息发送到另一台机器,该机器将付款添加到用户的帐户。每秒可能有数千次点击。事务的所有方面都应该是容错的。我以前从未遇到过这样的事情,但一些阅读表明这是一个众所周知的问题。所以我的问题。我假设安全的方法是使用两阶段提交,但协议(protocol)是阻塞的,所以我不会获得所需的性能,我是否正确?我通常写Ruby,但似乎Redis之类的数据库和Rescue、RabbitMQ等消息队列系统对我的帮助不大——即使我实现某种两阶段提交,如果Redis崩溃,数据也会丢失,因为它本质上只是内存。所有这些让我开始关注erlang和

  3. ruby-on-rails - 在这种情况下我如何模拟一个对象?没有明显的方法可以用模拟替换对象 - 2

    假设我在Store的模型中有这个非常简单的方法:defgeocode_addressloc=Store.geocode(address)self.lat=loc.latself.lng=loc.lngend如果我想编写一些不受地理编码服务影响的测试脚本,这些脚本可能已关闭、有限制或取决于我的互联网连接,我该如何模拟地理编码服务?如果我可以将地理编码对象传递到该方法中,那将很容易,但我不知道在这种情况下该怎么做。谢谢!特里斯坦 最佳答案 使用内置模拟和stub的rspecs,你可以做这样的事情:setupdo@subject=MyCl

  4. ruby - "public/protected/private"方法是如何实现的,我该如何模拟它? - 2

    在ruby中,你可以这样做:classThingpublicdeff1puts"f1"endprivatedeff2puts"f2"endpublicdeff3puts"f3"endprivatedeff4puts"f4"endend现在f1和f3是公共(public)的,f2和f4是私有(private)的。内部发生了什么,允许您调用一个类方法,然后更改方法定义?我怎样才能实现相同的功能(表面上是创建我自己的java之类的注释)例如...classThingfundeff1puts"hey"endnotfundeff2puts"hey"endendfun和notfun将更改以下函数定

  5. ruby - 在 RSpec 中 stub /模拟全局常量 - 2

    我有一个gem,它有一个根据Rails.env的不同行为的方法:defself.envifdefined?(Rails)Rails.envelsif...现在我想编写一个规范来测试这个代码路径。目前我是这样做的:Kernel.const_set(:Rails,nil)Rails.should_receive(:env).and_return('production')...没关系,只是感觉很丑。另一种方法是在spec_helper中声明:moduleRails;end而且效果也很好。但也许有更好的方法?理想情况下,这应该有效:rails=double('Rails')rails.sho

  6. ruby-on-rails - Ruby 长时间运行的进程对队列事件使用react - 2

    我有一个将某些事件写入队列的Rails3应用。现在我想在服务器上创建一个服务,每x秒轮询一次队列,并按计划执行其他任务。除了创建ruby​​脚本并通过cron作业运行它之外,还有其他稳定的替代方案吗? 最佳答案 尽管启动基于Rails的持久任务是一种选择,但您可能希望查看更有序的系统,例如delayed_job或Starling管理您的工作量。我建议不要在cron中运行某些东西,因为启动整个Rails堆栈的开销可能很大。每隔几秒运行一次它是不切实际的,因为Rails上的启动时间通常为5-15秒,具体取决于您的硬件。不过,每天这样做几

  7. ruby-on-rails - rspec 模拟对象属性赋值 - 2

    我有一个rspec模拟对象,一个值赋给了属性。我正在努力在我的rspec测试中满足这种期望。只是想知道语法是什么?代码:defcreate@new_campaign=AdCampaign.new(params[:new_campaign])@new_campaign.creationDate="#{Time.now.year}/#{Time.now.mon}/#{Time.now.day}"if@new_campaign.saveflash[:status]="Success"elseflash[:status]="Failed"endend测试it"shouldabletocreat

  8. ruby - 如何使用 rspec stub /模拟对命令行的调用? - 2

    我正在尝试测试命令行工具的输出。如何使用rspec来“伪造”命令行调用?执行以下操作不起作用:it"shouldcallthecommandlineandreturn'text'"do@p=Pig.new@p.should_receive(:run).with('my_command_line_tool_call').and_return('resulttext')end如何创建stub? 最佳答案 使用newmessageexpectationsyntax:规范/虚拟规范.rbrequire"dummy"describeDummy

  9. ruby - 接收 block 作为参数的模拟方法 - 2

    我有一个或多或少这样的场景classAdefinitialize(&block)b=B.new(&block)endend我正在对A类进行单元测试,我想知道B#new是否正在接收传递给A#new的block。我使用Mocha作为模拟框架。这可能吗? 最佳答案 我用Mocha和RSpec都试过了,虽然我可以通过测试,但行为不正确。从我的实验中,我得出结论,验证block是否已通过是不可能的。问题:为什么要传递一个block作为参数?block将用于什么目的?什么时候调用?也许这确实是您应该用类似的东西测试的行为:classBlockP

  10. ruby - 在不提供其所有属性的情况下获取队列 - 2

    我正在尝试为现有队列编写消费者。RabbbitMQ在一个单独的实例中运行,名为“org-queue”的队列已经创建并绑定(bind)到一个交换器。org-queue是一个持久队列,它还有一些额外的属性。现在我需要从这个队列接收消息。我使用下面的代码来获取队列的实例conn=Bunny.newconn.startch=conn.create_channelq=ch.queue("org-queue")它抛出一个错误,指出不同的耐用属性。默认情况下,Bunny似乎使用durable=false。所以我添加了durabletrue作为参数。现在它说明了其他参数之间的区别。我是否需要指定所有参

随机推荐