标签: queue

我正在寻找Java中的队列类型数据结构(最好是在标准库中),它具有以下属性:

• 我可以在结构中添加一个元素(推送)
• 我可以从结构中删除任意元素,而无需指定哪个元素,如remove()队列的操作.如果结构为空,显然会失败.
• 如果我向已经存在的结构添加元素,则不会添加两次.

保留插入/删除的顺序并不是非常重要.

Set结构没有重复,但没有pop操作,Queue结构不保证没有重复.是否符合我的需求？

为了避免XY问题,我正在做一个工作列表算法:需要更新的节点被添加到集合中,所以我想轻松弹出需要更新的下一个节点,并添加需要更新的节点而不需要更新如果它们已经在工作清单中,则重复.

我正在创建一个std::priority_queue使用std::vector容器.

似乎优先级队列在其构造函数中创建传递给它的容器的副本,因为在构造队列之后对容器所做的更改不会反映在队列的容器中.

例如,如果我调用clear()我的容器,优先级队列仍然是满的.

有没有办法在构建后维护对优先级队列的内部容器的引用？

我有一个带有两个线程的简单场景,其中第一个线程永久读取一些数据并将该数据排入队列.第二个线程首先从该队列中查看单个对象并进行一些条件检查.如果这些是好的,单个对象将被出列并传递给某些处理.

我试图使用ConcurrentQueue这是一个简单队列的线程安全实现,但这个问题是所有调用都是阻塞.这意味着如果第一个线程将对象排入队列,则第二个线程无法查看或出列对象.

在我的情况下,我需要在最后排队并同时从队列的开头出队.

C#的锁定语句也会.

所以我的问题是,是否可以并行执行这两个操作而不会以线程安全的方式相互阻塞.

这些是我的第一次尝试,这是我的问题的类似示例.

using System;
using System.Collections.Generic;
using System.Threading.Tasks;

namespace Scenario {
    public class Program {
        public static void Main(string[] args) {
            Scenario scenario = new Scenario();
            scenario.Start();
            Console.ReadKey();
        }

        public class Scenario {
            public Scenario() {
                someData = new Queue<int>();
            }

            public void Start() {
                Task.Factory.StartNew(firstThread);
                Task.Factory.StartNew(secondThread);
            }

            private void firstThread() {
                Random random = new Random();
                while (true) {
                    int newData = random.Next(1, 100);
                    someData.Enqueue(newData);
                    Console.WriteLine("Enqueued " + newData);
                }
            }

            private void …

我们曾经运行过Laravel 5.2，对于其中的一项处理任务，我们将运行控制台命令以将作业排队到Redis队列中。在Laravel 5.4升级之前，此作业将排队，并且将由队列守护程序拾取，并且只会运行一次。但是，升级后，作业被拾取两次，相隔大约1分钟。devop变更为零，所以我试图找出Laravel在做什么。我还可以验证console命令仅将作业排队一次，因此守护程序的运行方式有所更改。有没有其他人看到过这样的行为？

我成功地使在测试站点上工作的任务排队，并更新了实时站点（同一服务器）。现在，实时队列正在填充，没有经过处理或尝试。我正在使用伪造，并且正在运行一个队列进程。任何人都可以帮忙我接下来要检查的内容以找出为什么它无法正常工作

我做了一个malloc()调用的代码,但它返回一个空指针.当我调用相同malloc()的main()并传递给函数时,它工作得很好.请告诉我这是什么问题.

这是我的代码.我malloc()在函数中遇到问题reverse().malloc()其他功能中的s工作正常.那么为什么那个函数中存在问题呢？我的电脑里有足够的内存,所以绝对不是问题所在.

#include <stdio.h>
#include <stdlib.h>
typedef struct node
{
    int data;
    struct node *next;
} SNode;


typedef struct
{
    int count;
    SNode *top;
} Stack;

int isSEmpty(Stack *s)
{
    return (s->count==0);
}

void push(Stack *s, int x)
{
    SNode *temp = (SNode *)malloc(sizeof(SNode));
    temp->data = x;
    temp->next = s->top;
    s->top = temp;
    s->count++;
}

int pop(Stack *s)
{
    if (isSEmpty(s))
    {
        printf("Underflow");
        return -1;
    }
    SNode *temp …

我正在学习队列集合,我不明白为什么在使用PriorityQueue时我需要实现Comparable接口？我在数组/列表的自定义排序中使用了Comparable和Comparator接口.但是,当我不想对它进行排序时,为什么我需要为PriorityQueue实现...

在下面的示例中,我看到如果我没有实现Comparable接口,我就无法在PriorityQueue中添加元素.

对我来说很大的误解,在我运行此代码之后,列表没有按ID排序？我问这个问题是因为我看到compareTo()方法被覆盖了,当我想对列表进行排序时我使用这个方法.

我记得当我为列表完成自定义排序时,我已经使用了exaclty这个代码.列表按id排序.为什么在这种情况下队列没有排序？

抱歉我的英语语法.任何反馈将是apreciated!

import java.util.PriorityQueue;
import java.util.Queue;

    public class QueueExample {

        public static void main(String[] args) { 

            Queue<Book> queue = new PriorityQueue<>();

            //Creating Books  
            Book b1=new Book(121,"Let us C","Yashwant Kanetkar","BPB",8);  
            Book b2=new Book(233,"Operating System","Galvin","Wiley",6);  
            Book b3=new Book(101,"Data Communications & Networking","Forouzan","Mc Graw Hill",4); 
            Book b4=new Book(319,"Learn Java","Yanis Orhan","HEX",3);  
            Book b5=new Book(191,"Linux","Hadgy","Haman",7);  
            Book b6=new Book(287,"Python Programming","Tarzan","GEN",5); 

            //Adding Books to the queue  
            queue.add(b1);  
            queue.add(b2);  
            queue.add(b3);  
            queue.add(b4);  
            queue.add(b5);  
            queue.add(b6); 

            System.out.println("Traversing the queue elements:");  

            //Traversing queue elements  
            for(Book b : queue) {  

                System.out.println(b.id+" …

#include <stdio.h>
#include <stdlib.h>

typedef struct queue
{
    int *arr, // array to store values
    size, // queue size (array size)
    put, // index location which the next value will be pushed in
    take, // index location which the next value will be popped out
    countVals; // Counts the number of values that the queue contains
} queue;

// queue nitialization
void newQueue (queue *q, int size)
{
    if (size < 0)
        q->arr = NULL;
    else
    {
        q->arr = (int*) …

我跟随Laravel官方文档在Centos 7中使用主管在后台启动队列。