队列本身是有序列表,若使用数组的结构来存储队列的数据,则队列数组的声明如下图, 其中 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最终都会在队列顶部,所以上述队列只能一次性使用,没有达到复用的效果,因此我们要用到环形队列
思路:
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];
}
}
是的,我知道最好使用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
我有一个涉及多台机器、消息队列和事务的问题。因此,例如用户点击网页,点击将消息发送到另一台机器,该机器将付款添加到用户的帐户。每秒可能有数千次点击。事务的所有方面都应该是容错的。我以前从未遇到过这样的事情,但一些阅读表明这是一个众所周知的问题。所以我的问题。我假设安全的方法是使用两阶段提交,但协议(protocol)是阻塞的,所以我不会获得所需的性能,我是否正确?我通常写Ruby,但似乎Redis之类的数据库和Rescue、RabbitMQ等消息队列系统对我的帮助不大——即使我实现某种两阶段提交,如果Redis崩溃,数据也会丢失,因为它本质上只是内存。所有这些让我开始关注erlang和
假设我在Store的模型中有这个非常简单的方法:defgeocode_addressloc=Store.geocode(address)self.lat=loc.latself.lng=loc.lngend如果我想编写一些不受地理编码服务影响的测试脚本,这些脚本可能已关闭、有限制或取决于我的互联网连接,我该如何模拟地理编码服务?如果我可以将地理编码对象传递到该方法中,那将很容易,但我不知道在这种情况下该怎么做。谢谢!特里斯坦 最佳答案 使用内置模拟和stub的rspecs,你可以做这样的事情:setupdo@subject=MyCl
在ruby中,你可以这样做:classThingpublicdeff1puts"f1"endprivatedeff2puts"f2"endpublicdeff3puts"f3"endprivatedeff4puts"f4"endend现在f1和f3是公共(public)的,f2和f4是私有(private)的。内部发生了什么,允许您调用一个类方法,然后更改方法定义?我怎样才能实现相同的功能(表面上是创建我自己的java之类的注释)例如...classThingfundeff1puts"hey"endnotfundeff2puts"hey"endendfun和notfun将更改以下函数定
我有一个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
我有一个将某些事件写入队列的Rails3应用。现在我想在服务器上创建一个服务,每x秒轮询一次队列,并按计划执行其他任务。除了创建ruby脚本并通过cron作业运行它之外,还有其他稳定的替代方案吗? 最佳答案 尽管启动基于Rails的持久任务是一种选择,但您可能希望查看更有序的系统,例如delayed_job或Starling管理您的工作量。我建议不要在cron中运行某些东西,因为启动整个Rails堆栈的开销可能很大。每隔几秒运行一次它是不切实际的,因为Rails上的启动时间通常为5-15秒,具体取决于您的硬件。不过,每天这样做几
我有一个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
我正在尝试测试命令行工具的输出。如何使用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
我有一个或多或少这样的场景classAdefinitialize(&block)b=B.new(&block)endend我正在对A类进行单元测试,我想知道B#new是否正在接收传递给A#new的block。我使用Mocha作为模拟框架。这可能吗? 最佳答案 我用Mocha和RSpec都试过了,虽然我可以通过测试,但行为不正确。从我的实验中,我得出结论,验证block是否已通过是不可能的。问题:为什么要传递一个block作为参数?block将用于什么目的?什么时候调用?也许这确实是您应该用类似的东西测试的行为:classBlockP
我正在尝试为现有队列编写消费者。RabbbitMQ在一个单独的实例中运行,名为“org-queue”的队列已经创建并绑定(bind)到一个交换器。org-queue是一个持久队列,它还有一些额外的属性。现在我需要从这个队列接收消息。我使用下面的代码来获取队列的实例conn=Bunny.newconn.startch=conn.create_channelq=ch.queue("org-queue")它抛出一个错误,指出不同的耐用属性。默认情况下,Bunny似乎使用durable=false。所以我添加了durabletrue作为参数。现在它说明了其他参数之间的区别。我是否需要指定所有参