queue相关内容
更新:这是我对哈希计时轮的实现.如果您有提高性能和并发性的想法,请告诉我.(2009 年 1 月 20 日) //示例用法:公共静态 void main(String[] args) 抛出异常 {计时器 timer = new HashedWheelTimer();for (int i = 0; i 更新:我使用 分层和散列计时轮.(2009 年 1 月 19 日) 我正在尝试在 Ja
..
我的 php 服务器出现问题(我的计算机是唯一的连接).我最初认为部分原因是因为 ajax 请求太多(我有一个脚本,每次击键执行一个 ajax 请求),所以我实现了一个设计来控制 ajax 请求进入队列的流程.以下是我的代码: //全局变量:activeAjaxThread = 0;//var 描述 ajax 线程状态ajaxQue = [];//队列中的ajax请求对象数组,在前一个请求完成后
..
每当外部程序 (TCPdump) 在我的目录中创建 *.pcap 文件时,我有这段代码应该将事件放入队列中.我的问题是我总是得到一个空队列,尽管我从 process() 函数得到了打印. 我做错了什么?队列是否正确定义并在两个类之间共享? 编辑----------------- 我可能明白为什么我有一个空队列,我认为这是因为我正在打印我在 Handler 类填充之前初始化的队列.我修
..
我有以下代码: 队列oldQueue = 新队列();oldQueue.Enqueue("一个");oldQueue.Enqueue("两个");oldQueue.Enqueue("三");队列 newQueue = oldQueue;字符串 newString = newQueue.Dequeue(); 问题是,一旦我将项目从 newQueue 中出列,该项目也会从 oldQueue 中出列
..
我需要为响应创建一个临时队列,但我需要知道是否可以在不通过消息的 setJMSReplyTo 方法发送响应队列对象的情况下连接到临时队列,因为回复线程根本没有得到该对象. 解决方案 我使用 InitialContext 对象将我的临时队列绑定到 jndi,这样我就可以从需要使用我的临时队列的线程中查找我的临时队列. jndiContext = new InitialContext();c
..
我需要向程序中运行的每个线程发送信息,并且每个线程都必须处理该信息. 我不能使用常规队列来做到这一点,因为一旦一个线程从队列中删除数据,所有其他线程将无法再看到它. 实现这一目标的最佳方法是什么? 解决方案 一种方法是为每个线程设置一个队列,广播信息的函数负责将消息插入到每个线程的队列. 例如,这类似于消息队列在 Windows 中的工作方式.每个执行 GUI 操作的线程
..
我正在尝试用 boost::lockfree::queue 替换此文件中的 std::queue https://github.com/zaphoyd/websocketpp/blob/experimental/examples/broadcast_server/broadcast_server.cpp 我添加了 #include ;更改行
..
我在 Python 3 中有一个脚本,我正在尝试使用 tkinter 为它制作一个 GUI. 这是一个完整的工作代码示例: #!/usr/bin/python# 编码:utf-8进口泡菜导入openpyxl从 tkinter 导入 *导入线程导入队列类工人():def __init__(self):self.one_name_list = []self.dic = {}self.root
..
我只是在处理具有可变数据大小的 FIFO 队列(简单的队列,即首先推送的内容,首先弹出),但我不确定我的设计方式.我将存储在那里的数据类型将提前知道,假设对于此类的每个实例都是相同的.我正在考虑使用 TList 来存储具有以下定义的记录(@David - 它适用于 D2007,所以我没有 Generics.Collections 可用 :) 类型PListItem = ^TListItem;TL
..
我在一个队列上启动了一堆线程,我想在发送 SIGINT (Ctrl+C) 时终止它们.处理这个问题的最佳方法是什么? targets = Queue.Queue()线程数 = 10线程= []对于threads_num中的我:t = 我的线程()t.setDaemon(真)线程.append(t)t.start()目标.join() 解决方案 不是Ctrl+C SIGINT吗? 无论如
..
我需要实现一种任务缓冲区.基本要求是: 在单个后台线程中处理任务 从多个线程接收任务 处理所有接收到的任务,即确保在收到停止信号后缓冲区中的缓冲任务已耗尽 必须保持每个线程接收到的任务的顺序 我正在考虑使用如下所示的队列来实现它.将不胜感激有关实施的反馈.还有其他更好的想法来实现这样的事情吗? 公共类TestBuffer{私有只读对象 queueLock = new objec
..
我正在尝试使用 Java Thread 创建一个简单的队列,该队列将允许一个循环,例如一个具有 10 次迭代的 for 循环,一次迭代 n (
..
我正在使用 Eclipse 的 Java MQ 类编写一个简单的 Java 应用程序. 现在我可以浏览远程队列而无需删除存储的消息. 下面是阅读循环的代码: MQQueueManager QMgr = new MQQueueManager(qManager);//
..
我正在寻找一种从特定打印机获取作业列表或数量的方法.在最好的情况下,我希望有一个“作业对象",它代表一个打印作业及其在打印队列中的名称. 这是必需的,因为我需要监控打印机的状态,这样我就可以用一批新文档重新填充打印队列,而不会溢出打印后台处理程序 提前致谢! 编辑:添加解决方案的代码片段 private int GetNumberOfPrintJobs(){LocalPrint
..
Okasaki 描述了可以在 Haskell 中使用类型实现的持久实时队列 数据队列 a = forall x .队列{前::[a], 后方 :: [a], 时间表 :: [x]} 增量旋转保持不变 长度表 = 前长 - 后长 更多详情 如果您熟悉所涉及的队列,则可以跳过此部分. 旋转函数的样子 旋转 :: [a] ->[一]->[一]->[一个]旋转 [] (y : _)
..
我将 ListBox 绑定到 Queue.当我将项目入队/出队时,ListBox 不会更新. 我有帮助入队/出队来提高属性更改 protected void EnqueueWork(string param){队列.入队(参数);RaisePropertyChanged("队列");}受保护的字符串 DequeueWork(){字符串 tmp = Queue.Dequeue();Raise
..
我有一个生产 laravel 应用程序和在同一台服务器上运行的暂存应用程序.我正在运行 redis,我将其用作队列驱动程序.它们显然连接到不同的数据库.问题是从登台应用程序推送到红色队列的作业是否会干扰生产数据库,反之亦然. 解决方案 您可以设置 Laravel 用于 Redis 缓存的前缀.默认情况下这是 laravel,所以所有的键都存储为 laravel:keyname 并且 Lar
..
我有一个阻塞的对象队列. 我想写一个线程阻塞直到队列中有一个对象.类似于 BlockingQueue.take() 提供的功能. 但是,由于我不知道我是否能够成功处理该对象,所以我只想 peek() 而不是删除该对象.只有当我能够成功处理它时,我才想删除它. 所以,我想要一个阻塞 peek() 函数.目前,根据 javadocs,如果队列为空,peek() 只会返回. 我错
..
我之前有一个问题,我已经提供了我的解决方案;但是,由于我使用的是 .Net 3.5,因此我无法访问 ConcurrentQueue.我需要 Queue 来允许并发.我读了这个 问题,如果一个项目是 不在队列中,并且线程方法尝试使项目出队. 我现在的任务是确定我是否可以派生我自己的并发队列类.这是我想出的: 公共密封类 ConcurrentQueue : Queue{公共事件Ev
..
如果我对 ThreadPool 工作方式的理解是正确的,那么它的目的之一就是限制在给定时间可以创建的进程中的工作线程数.例如,如果您将 MaxThreads 设置为 5,然后调用 QueueUserWorkItem 30 次,则会向 ThreadPool 发出 30 个请求,但其中只有 5 个请求会被新线程处理,而其他 25 个请求将被添加到队列中并在之前的请求完成且现有线程可用时一次提供一个服务
..