多处理队列批量获取最多 N 个元素

2023-12-28

我需要以阻塞方式从队列中获取尽可能多的项目(最多 N 个)。例如:

queue.get(16)

最多应返回 16 个元素,但如果为空则阻塞。


没有内置这样的工具,因此您需要自己编写代码;例如,

import queue  # in Python 3; Queue in Python 2
...
def getn(q, n):
    result = [q.get()]  # block until at least 1
    try:  # add more until `q` is empty or `n` items obtained
        while len(result) < n:
            result.append(q.get(block=False))
    except queue.Empty:
        pass
    return result

Then do getn(queue, 16)为你的概念queue.get(16).

本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)

多处理队列批量获取最多 N 个元素 的相关文章

  • 在 Django 1.6 中结合 DetailView 和 CreateView

    我有 2 个独立的模型 帖子和评论 我使用 DetailView 来显示帖子内容 并且我想使用 CreateView 在同一页面上显示评论创建表单 最干净的方法是什么 唯一想到的是使用自定义视图 它既获取对象又处理评论表单 但这看起来太脏了
  • Python dict 到 DataFrame Pandas - 级别

    几个月前 Romain X 在这个问题上帮了我很多忙 Python 字典到 DataFrame Pandas https stackoverflow com questions 32770359 python dict to datafra
  • 如何使用 Julia 查找矩阵中的连通分量

    假设我有以下矩阵 此处用 Julia 语言定义 mat 1 1 0 0 0 1 1 0 0 0 0 0 0 0 1 0 0 0 1 1 将一组值为 1 的相邻元素视为一个 分量 如何识别该矩阵有 2 个分量以及每个分量由哪些顶点组成 对于矩
  • 在python中合并3个dict()

    如果多个字典之间有公共字符串 是否有逻辑合并多个字典的方法 即使这些公共字符串在一个 dict 的值与另一个 dict 的键之间匹配 我在 SO 上看到了很多类似的问题 但似乎没有一个问题能解决我将 较低级别文件 中的多个键与较高键 值中的
  • pandas DataFrame:获取上个月缺少交易且无法移位()的值

    有没有办法在不生成虚拟行的情况下实现这一点 这是我的数据源 Group Store Month Revenue Group1 A 201611 10 Group1 A 201612 20 Group1 A 201701 30 Group1
  • 在 Windows 上的 python2.5 上安装 Openpyxl

    我努力了easy install install openpyxl and python setup install 两者都失败了 我也尝试过easy install openpyxl并再次失败 我包括了我得到的输出 当我尝试时easy i
  • Python矩阵问题[重复]

    这个问题在这里已经有答案了 这是从这个线程继续的 Python矩阵 有什么解决方案吗 https stackoverflow com questions 5835583 python matrix any solution Input fr
  • 为什么 Numpy 创建零数组比用零替换现有数组的值要快得多?

    我有一个用于跟踪各种值的数组 数组是2500x1700尺寸上 所以不是很大 在会话结束时 我需要将该数组中的所有值重置为零 我尝试创建一个新的零数组并将数组中的所有值替换为零 并且创建一个全新的数组要快得多 代码示例 for in sess
  • Python:当为变量分配新内容时,“旧”内存是否被释放?

    如果为变量分配了任何新内容 为 旧内容 分配的内存是否会 正确 释放 例如 在以下脚本中 在为 a 分配一些新内容后 变量 a 作为零数组的内存是否会被释放 import numpy a numpy zeros 1000 a a 1 我想象
  • 如何在 Django Admin 中禁用事务?

    I used transaction non atomic requests for 被超越的save in Person model如下所示 store models py from django db import models fro
  • Netmiko OSError:在 send_command 中从未检测到搜索模式:

    我被这个错误困住了 任何人都可以帮助摆脱这个错误 import netmiko Device host xxxxxxxxxx device type cisco nxos username admin password xxxxxxxx c
  • Keras 中的条件批量归一化

    我正在尝试在 Keras 中实现条件批量标准化 我假设我必须创建一个自定义层 因此 我从正常化 https github com keras team keras blob master keras layers normalization
  • 使用 Pytest 捕获 SystemExit 消息

    我正在使用 pytest 编写测试 我遇到了一些函数抛出异常的情况SystemExit如果输入错误 终端上会显示一些错误消息 我想为以下情况编写测试SystemExit抛出并验证输出错误消息中是否有特定字符串 这是代码 def test v
  • iter(fp.readline, '') 中的行而不是 fp 中的行:

    我读了内置函数iter的例子在内置函数 Python 3 7 0 文档 https docs python org 3 library functions html iter with open mydata txt as fp for l
  • Python、Oracle DB、列中的 XML 数据,获取 cx_Oracle.Object

    我正在使用 python 从 Oracle DB 获取数据 所有行都有一个包含 XML 数据的列 当我使用 python 打印从 Oracle DB 获取的数据时 包含 XML 数据的列将打印为 0x7fffe373b960 处的 cx O
  • Django populate() 不可重入

    当我尝试在生产环境中加载 Django 应用程序时 我不断收到此消息 我尝试了所有的 stackoverflow 答案 但没有任何解决办法 任何其他想法 我使用的是 Django 1 5 2 和 Apache Traceback most
  • 无法使用 Python 3 编写的 gzip.open() 将压缩文件上传到云存储

    当我尝试在 Cloud Shell 实例上使用 python 脚本将压缩的 gzip 文件上传到云存储时 它总是上传一个空文件 这是重现错误的代码 import gzip from google cloud import storage s
  • 将 PySpark RDD 作为新列添加到 pyspark.sql.dataframe

    我有一个 pyspark sql dataframe 其中每一行都是一篇新闻文章 然后我有一个 RDD 来表示每篇文章中包含的单词 我想将单词的 RDD 作为名为 单词 的列添加到我的新文章数据框中 我试过 df withColumn wo
  • 使用 Python PuLP 混合整数规划的时间限制

    我一直在使用PuLP http pythonhosted org PuLP 解决我感兴趣的特定混合整数线性规划 MIP 但是 随着问题规模的增长 PuLP 花费的时间太长 我希望能够运行求解器一段时间 并在需要很长时间的情况下提前终止它 并
  • Pepper Robot:如何将 Python 地标检测移植到 Choregraphe?

    我正在尝试编写一个小程序 让 Pepper 通过 Choregraphe 检查房间内的地标 用于地标检测的常规 Python 代码工作得很好 但我无法将其移植到 Choregraphe http doc aldebaran com 2 5

随机推荐

  • 如何使用 JavaScript(外部域)解析 RSS 提要?

    Question 我需要解析 RSS 提要并在 HTML 页面中显示解析的详细信息 我找到的解决方案 如何使用 JavaScript 解析 RSS 提要 https stackoverflow com questions 10943544
  • 如果浏览器中未启用 JavaScript,则显示消息

    我正在寻找一种解决方案 如果我的网站的访问者没有启用 JavaScript 则向他显示一条信息消息 我在 div 中尝试了一条消息 该消息默认可见 但在启动时立即被 jQuery 函数隐藏 问题是 该消息在短时间内可见 直到它被隐藏 这非常
  • 如何在正则表达式中指定单引号

    这是我的正则表达式 我想在 O Neal Nickel 等字符中包含单引号 这是我的正则表达式 允许字母 空格以及句号 和 连字符 A Za z s A Za z s 还是我问错了你的问题
  • 您可以使用 Sel-Blocks Selenium 插件指定数据文件的“相对”路径吗?

    使用 SelBlocks 插件进行数据驱动开发时 指定数据文件的位置时是否可以指定相对路径 而不是绝对路径 我在一个小团队工作 我们希望能够让我们的测试可移植并最终成为我们生产过程的一部分 我们目前正在使用 Selenium IDE 来编写
  • Mantle自动将0和1转换为BOOL?

    Mantle 是否已将 JSON 中的 int 值 0 和 1 转换为 Objective C BOOL 值 我有一个模型 interface MyModel MTLModel property nonatomic readonly BOO
  • Ruby on Rails 和 Jquery:提交后尝试切换字符

    第一篇文章在这里 所以如果有些事情不对 我如何放入代码 如果我没有包含足够的内容 或者如果我的问题太模糊 我深表歉意 我对 RoR 非常非常陌生 我正从构建一款井字棋游戏开始 我已经将其构建为可以在命令行上运行 现在我正在尝试使其基于网络
  • 如何确保在运行 Jenkins 管道之前更新参数列表?

    Jenkins 管道项目配置为获取其Jenkinsfile来自 Git 存储库 例如 如果我更改参数列表 properties parameters string name FOO description Choose foo to pro
  • Firebase 导致“线程 1:信号 SIGABRT”

    我启动了一个空白的 Xcode 项目 我所做的就是通过 Cocoapods 添加 Firebase 框架并导入 Appdelegate 和 viewcontroller 当我添加FIRApp configure to didFinishLo
  • 在 Android 中通过 Intent 传递信息后将项目添加到 listView

    我正在尝试添加一个项目 首先使用添加按钮 然后转到不同的活动 然后返回原始活动并将其添加到列表视图中 我似乎不能拥有超过一件物品 AddScreen class 我的第一个活动 package com painLogger IMPORTS
  • 如何在C++中读取空字符串?

    考虑 C 中的这段代码片段 string str cin gt gt str 如果我在这个阶段简单地按回车键 指针就会移动到下一行 但会继续等待输入 即使我故意想输入一个空字符串 我的目标是读一个单词 如果我按 Enter 键 它应该被视为
  • 手机是否需要连接到互联网以便网络提供商可以确定位置?

    手机是否需要始终连接到互联网 以便网络提供商可以确定位置 当我在手机上测试我的应用程序时Settings gt Location only Use wireless network已选中 并且我未通过 Wi Fi 连接到互联网 因此无法获取
  • 将 Git 与 TFS 2017 结合使用 - 可在 Visual Studio 中使用,但不能在命令行中使用

    最近 我们的项目使用 Git 切换到 Team Foundation Server 2017 如果我们通过 Web 界面或 Visual Studio 使用它 我们的 TFS 工作得足够好 但如果我们尝试使用第三方工具 如 Sourcetr
  • 在核心数据持久存储中传送静态(只读)数据的正确方法是什么?

    我想发送静态只读数据以在我的核心数据模型中使用 问题是 存在明显不同的持久存储类型 我不知道这些类型的格式是否应该是不透明的 或者我是否应该能够手动构造它们 现在我只有一个 plist 而且非常小 总共可能有 30 个条目 我是否应该在首次
  • 将 pdf 附件添加到 WooCommerce 已完成订单电子邮件通知

    在另一个线程上找到此代码 但无法使其工作 PDF 上传到 wp content child theme 目标是将 pdf 附加到 woocommerce 将发送的已完成订单电子邮件中 不知道customer completed order是
  • 在map.forEach期间map.delete(key)

    通常 当您循环访问列表时 无法安全地从列表中删除项目 这个概念对于 ES6 地图仍然适用吗 我尝试了这个简单的测试 没有例外 var map new Map a 1 b 2 c 3 map forEach value key map gt
  • 捕获 Windows 上的访问违规

    我试图捕获应用程序中所有未处理的异常 以便在发生异常时可以保存日志文件 这是一个使用 Visual Studio 2013 编译的 64 位 Windows 应用程序 用 C 编写 为了进行测试 我使用 VS 生成的默认 C Win32 项
  • rebol解析函数可以创建完全解析css2/css3的规则吗?

    rebol 解析函数的能力有限制吗 它是否能够解析整个 css2 css 3 规范 或者是否会遇到理论上不可能形成某些规则的情况 HostileFork 回答后更新 我的意思是在正则表达式中我认为这是相当不可能的 解析是否更强大 如果是 这
  • Angular 指令中的单向绑定

    官方Angular 文档用于编译 https docs angularjs org api ng service 24compile讨论单向绑定类型 lt 在角社区 I see 通常称为 单向绑定类型 是什么赋予了 这 在我看来 这并不是真
  • Python 中单独线程中的按键回显不显示第一个击键

    我会尝试发布一个最小的工作示例 但不幸的是这个问题只需要很多部分 所以我已尽我所能将其剥离 首先 我使用一个简单的脚本来通过函数调用模拟按键 这是调整自here https stackoverflow com a 13290031 2924
  • 多处理队列批量获取最多 N 个元素

    我需要以阻塞方式从队列中获取尽可能多的项目 最多 N 个 例如 queue get 16 最多应返回 16 个元素 但如果为空则阻塞 没有内置这样的工具 因此您需要自己编写代码 例如 import queue in Python 3 Que