使用 PHP 进行异步处理 - 每个作业一名工人
考虑一个 PHP Web 应用程序,其目的是接受用户请求来启动通用异步作业,然后创建一个工作进程/线程来运行该作业。这些作业并不是特别密集的 CPU 或内…
是否有复杂的 Java WorkQueue API?
我正在寻找一个提供以下功能的 WorkQueue API: java.util.Queue 兼容 提供(可选) 设置语义 单处理和批处理 并发(当然) 调度 不同的处理策略 等待…
如何从代码中取消 Google App Engine 任务队列中的任务
我正在开发一个 GAE 应用程序,它将采用逗号分隔的列表并从中创建批处理作业。我想在给定时间将任意一项批处理作业中的一项任务添加到任务队列中。这…
Google App Engine:任务队列上的bucket_size参数
关于 Bucket_size 参数的 Google 文档仅提供了简要说明定义、维基百科链接和示例: bucket_size 限制队列处理的突发性, 即更大的桶尺寸允许更大的尖…
App Engine - 使用 Mapper API 进行任务队列重试计数
这就是我想做的: 我使用新的 Mapper API 设置了 MapReduce 作业。这基本上工作得很好。 问题是任务队列重试所有失败的任务。但其实我不想让他这么做…
Google App Engine:如何使用任务队列进行此处理?
我正在使用 Python GAE SDK。 我需要对 6000 多个 MyKind 实例进行一些处理。在单个请求中完成速度太慢,因此我使用任务队列。如果我让一个任务只处理…
应用程序引擎任务可以获取其运行次数吗?
我每小时在 Google App Engine 中运行数千个任务,其中大约 0.1% 即使在多次重试后也会失败。理想情况下,我希望他们停止尝试并退出。然而,由于应用…
在应用程序引擎任务队列中传递多个参数(JAVA)
有没有办法在 google-app-engine 的队列中传递多个参数? 我在我的 servlet 中使用下面的代码, Queue queue = QueueFactory.getQueue("sms-queue"); …
bigtable需要锁吗?
我正在使用任务队列来更新 GAE 中的某些数据。 我的queue.xml 文件如下所示 data-processing 20/s 我的队列处理servlet 将每个任务的信用值减少1。 在…
App Engine 中的自定义任务队列?
我创建了一个新的任务队列并在queue.yaml中定义它 我不知道如何开始将任务添加到该队列? 使用默认队列很简单 taskqueue.add(...) 我们如何为自定义队…
setQueueXmlPath 的基础
我不知道如何在队列配置文件中指向单元测试。 单元测试片段 // TaskQueue setup LocalTaskQueueTestConfig tqConfig = new LocalTaskQueueTestConfig(…