jjzjj

task-queue

全部标签

javascript - task.js 生成器/ promise 与异步回调

我想知道在处理JavaScript中的异步代码时,这两种方法中哪种方法更好。我想了解哪种方法可以生成更清晰的代码。我习惯于使用promises,它们似乎比异步方法(https://github.com/caolan/async)更灵活。我也知道Task.js库(http://taskjs.org/),但这依赖于作为EcmascriptHarmony一部分的yield关键字。 最佳答案 async库封装了几个非常常见的异步模式,包括并行进行任意异步调用和异步迭代列表。它旨在与“nodeback”(err,res)API一起使用,这使得

javascript - "Warning: Task "巴别塔 "not found. Use --force to continue."

我的gruntfile.js中有这个简单的代码:module.exports=function(grunt){require("load-grunt-tasks")(grunt);//npminstall--save-devload-grunt-tasksgrunt.initConfig({babel:{options:{sourceMap:true},dist:{files:{"dist/app.js":["src/app.js"]}}}});grunt.registerTask("default",["babel"]);};但是运行时显示这个错误:Warning:Task"babe

javascript - 为什么我会在 gulp 中得到 "task completion callback called too many times"?

给定以下gulp任务,为什么我会收到以下错误?Error:taskcompletioncallbackcalledtoomanytimesfunctionmyTask(options,cb){//cbisthegulpcbvarserverInstance=http.createServer(dispatch({/*routes*/}));serverInstance.listen(options.port,function(){cb();//Stacktraceidentifiesthislineasthrowingtheerror});}functionpartial(fn){va

javascript - Gulp.js : task based on forEach loop

我有一个对象数组,如下所示。varbundles=[{src:'js/my-component/*.js',bundleName:'my-component.js'},{src:'js/my-other-component/*.js',bundleName:'my-other-component.js'}]我希望gulp任务处理/连接数组中的每个条目,但它似乎不起作用。gulp.task('bundlejs',function(){returnbundles.forEach(function(obj){returngulp.src(obj.src).pipe(concat(obj.bu

go - 是否可以将 Go Task runner 配置为使用文件扩展名 yaml?

是否可以配置Go任务运行器(https://taskfile.dev/)以使用文件扩展名为“yaml”而不是“yml”的文件? 最佳答案 任务作者在这里。目前唯一的方法是运行:task--taskfile=Taskfile.yaml或task-tTaskfile.yaml也就是说,有一个openissue和一个openPR关于使.yaml扩展自动工作,因此最终将在没有标志的情况下工作。 关于go-是否可以将GoTaskrunner配置为使用文件扩展名yaml?,我们在StackOverf

memory - Go 中的磁盘备份数组

如何在Go中创建基于磁盘的延迟队列?我正在编写一个Go程序,以便在特定时间间隔后对数据执行特定操作。这是精简版。funcIncomingJob(dataMyStruct){//Runimmediatelydosomething(&data,1)time.Sleep(5*time.Minute)//Runafter5minuteshaspassedfrominitialarrivaldosomething(&data,2)time.Sleep(5*time.Minute)//Runafter10minuteshaspassedfrominitialarrivaldosomething(&

google-app-engine - GAE (go) 推送队列率未强制执行

我正在尝试让推送队列中的某些任务以大约每秒一次的速度执行。下面是我如何定义我的queue.yamlqueue:-name:defaultrate:1/sbucket_size:1max_concurrent_requests:1我有一个处理程序(用于/tasks/readalerts),它将任务排入队列:t:=taskqueue.NewPOSTTask("/tasks/readalerts",map[string][]string{})if_,err:=taskqueue.Add(context,t,"");err!=nil{context.Errorf("%v",err)}一旦我访问

go - 非对等服务器上的分布式计算

我有一组任务,每个任务都需要满足某些特定条件。例如,任务需要100Mb的RAM才能执行。我还有多个放置worker的服务器。每个worker都有一些配置来描述它拥有多少资源。例如,一些工作人员可以使用1Gb的RAM来执行任务。是否有在worker之间分配任务的系统,以便每个worker满足传递给它的任务的要求?或者也许我可以通过消息代理(例如RabbitMQ)以某种方式做到这一点?我知道为此编写自己的应用程序,因为我不想重新发明轮子。Worker是用Go编写的。 最佳答案 RabbitMQ并没有明确地知道关于它的客户端的这些事情。它

go - tarantool 队列尝试索引全局 'queue'

我的行有错误:que:=queue.New(conn,"foobar"):错误评估:1:尝试索引全局“队列”(零值)(0x20)配置文件:(如果我删除box.once则存在错误管)如何更正配置中的初始用户和管道,而不会出现“用户已存在”错误?`box.cfg{listen=3303}localqueue=require('queue')queue.start()queue.create_tube('foobar','fifottl',{if_not_exists=true})box.once("init",function()box.schema.user.grant('guest',

http - 戈朗 : strategies to prevent connection reset by peer errors

该程序同时生成许多goroutines(getStock),我相信这会导致远程服务器立即断开连接。我不是要创建DOS,但我仍然想在不出现“连接重置”错误的情况下积极获取数据。最多只能有N(例如20)个同时连接的策略是什么?golang的Http客户端有内置GET请求队列吗?我仍在学习,如果能了解是否有针对此类代码的更好设计模式,那就太好了。输出$goruns1w.gosl(size):1280body:"AAPL",17.92body:"GOOG",32.13body:"FB",42.02body:"AMZN",195.83body:"GOOG",32.13body:"AMZN",19