当前位置：首页 > 软件库 > 程序开发 > 并发/并行处理框架 >

taskq

Golang 异步任务/作业队列

授权协议 BSD-2-Clause

开发语言 Google Go

所属分类程序开发、并发/并行处理框架

软件类型开源软件

地区不详

投递者田瀚

操作系统跨平台

开源组织无

适用人群未知

软件概览

taskq 是一个带有 Redis、SQS、IronMQ 和内存后端的 Golang 异步任务/作业队列。

特性：

Redis、SQS、IronMQ 和内存后端。
自动缩放用于获取（fetcher）和处理消息（worker）的 goroutines 的数量。
全局速率限制。
工人的全球限制。
调用一次 - 删除具有相同名称的重复消息。
使用指数退避自动重试。
当队列中的所有消息都失败时自动暂停。
用于处理失败消息的后备处理程序。
消息批处理。它用于 SQS 和 IronMQ 后端批量添加/删除消息。
使用 snappy / s2 自动压缩消息。

API overview

t := myQueue.RegisterTask(&taskq.TaskOptions{
    Name:    "greeting",
    Handler: func(name string) error {
        fmt.Println("Hello", name)
        return nil
    },
})

// Say "Hello World".
err := myQueue.Add(t.WithArgs(context.Background(), "World"))
if err != nil {
    panic(err)
}

// Say "Hello World" with 1 hour delay.
msg := t.WithArgs(ctx, "World")
msg.Delay = time.Hour
_ = myQueue.Add(msg)

// Say "Hello World" once.
for i := 0; i < 100; i++ {
    msg := t.WithArgs(ctx, "World")
    msg.Name = "hello-world" // unique
    _ = myQueue.Add(msg)
}

// Say "Hello World" once with 1 hour delay.
for i := 0; i < 100; i++ {
    msg := t.WithArgs(ctx, "World")
    msg.Name = "hello-world"
    msg.Delay = time.Hour
    _ = myQueue.Add(msg)
}

// Say "Hello World" once in an hour.
for i := 0; i < 100; i++ {
    msg := t.WithArgs(ctx, "World").OnceInPeriod(time.Hour)
    _ = myQueue.Add(msg)
}

// Say "Hello World" for Europe region once in an hour.
for i := 0; i < 100; i++ {
    msg := t.WithArgs(ctx, "World").OnceInPeriod(time.Hour, "World", "europe")
    _ = myQueue.Add(msg)
}

使用案例

ZFS on Linux performance tuning when zfs_iput_taskq take near 100% CPU

一台机子的zfs_iput_taskq进程CPU占用100%. 处理方法 : # cat /etc/modprobe.d/zfs.conf options zfs zfs_arc_max=10240000000 # zfs list NAME USED AVAIL REFER MOUNTPOINT zp1 548M 267G 136K /zp1

相关资料

Redis队列在Rails中处理异步任务

编辑：Redis+Sidekiq完成该工作。在这里，Redis作为一个消息队列工作，Sidekiq在后台处理这些消息。我很想知道，选择一个显式代理（如RabbitMQ、SQS、Redis PubSub）而不是Redis+SideKiQ有什么用例和好处？
RESTEasy异步作业服务+Spring MVC？

我正在使用RESTEasy与Spring MVC的集成，如“39.2.Spring MVC集成”一节http://docs.jboss.org/RESTEasy/docs/2.0.0.ga/userguide/html/resteasy_spring_integration.html所述我想试验一下Resteasy对“异步作业服务”的实现，如下所述:http://docs.jboss.org/r
Activiti异步服务任务的作业执行者问题（Activiti>=5.17）

请考虑下图 MyProcess.bpmn 为了用文字来描述它，有一个用户任务（评估）和一个附加到它的计时器（配置为在2秒内触发）。触发计时器后，其Java委托中的Timed自动完成异步服务任务尝试完成用户任务（评估）。完成用户任务（评估）后，流移动到另一个异步服务任务（存储文档），它调用其Java委托，，流结束。计时器ervice.java StoreDocsService。Java语言应用程
3.7 AsyncTask异步任务

主要内容：本节引言：,1.相关概念,2.AsyncTask全解析：,3.AsyncTask使用示例：,本节小结：本节引言：本节给大家带来的是Android给我们提供的一个轻量级的用于处理异步任务的类:AsyncTask，我们一般是继承AsyncTask，然后在类中实现异步操作，然后将异步执行的进度，反馈给UI主线程~ 好吧，可能有些概念大家不懂，觉得还是有必要讲解下多线程的概念，那就先解释下一些概念性的东西吧！ 1.相关概念 1）什么是多线程：答：先要了解这几个名称：应用程序，进程，线程，
异步任务发出警告，（不）异步任务发出错误

这可能是一个更巧妙的问题，但我在ViewComponent类中有以下方法所以我的问题是我应该采取什么方法？让异步在那里与警告无关，还是有一个解决方案/修复这个警告？它对我的项目有那么大的影响吗？谢了！
8.2 使用异步任务

8.2 使用异步任务注意：本节所介绍的功能要求 vim 编译包括 +job 特性。 8.2.1 简单任务体验前文说到，Vim 的异步任务主要是针对外部命令的。那我们就先以最简单最常见的系统命令 ls 为例，其功能是列出当前目录下的文件，若在 Windows 操作系统下或可用 dir 命令代替。首先请在 shell 中进入一个非空目录，便于实践，并在 shell 中执行如下命令： $ ls
异步运行PHP任务

问题内容：我在一个比较大的Web应用程序上工作，后端主要使用PHP。代码中有几个地方需要完成一些任务，但是我不想让用户等待结果。例如，在创建新帐户时，我需要向他们发送欢迎电子邮件。但是，当他们按下“完成注册”按钮时，我不想让他们等到实际发送电子邮件之后，我只想开始该过程，并立即向用户返回一条消息。到目前为止，在某些地方，我一直在使用exec（）感觉像是被黑客入侵。基本上是这样的：这似乎可行，
异步任务Android执行

这是在一次Android采访中被问到的。有人问我是否可以从异步任务 1 的 doInBackground（）方法（让它成为 Task1）启动另一个异步任务（让它成为 Task2）。我浏览了文档，其中说了以下内容：必须在UI线程上创建任务实例。必须在 UI 线程上调用 execute（Params...）。根据这些陈述，我认为从另一个任务的后台方法启动一个任务是不可能的。此外，async任务

taskq

同类工具

相关阅读

相关文章

相关问答

相关文档