草庐IT

Async-Awati

全部标签

node.js - Node : Async job queue processing

我在nodejs中使用express开发一个经常与mongodb通信的网络应用程序。目前,我使用自己的作业队列系统运行生产,该系统仅在前一个作业完成后才开始处理作业(kue似乎采用了这种方法)。对我来说,这似乎非常低效,我希望有一个更加异步的作业队列,所以我正在寻找一些关于其他nodejs开发人员如何对他们的作业进行排队和构建他们的处理的建议。我的一个想法是处理任何立即收到的作业,并按添加顺序返回结果数据。还要考虑:目前每个用户都有自己独立的作业队列实例,这是正常做法吗?有什么理由不应该这样吗?(即,所有用户都将作业发送到一个通用队列?)如有任何意见/建议,我们将不胜感激。

ruby-on-rails - Sidekiq perform_async 未触发

我正在使用Sidekiq创建Elasticsearch回调。我启动了Redis和Sidekiq,并在Rails控制台中创建了一个对象,但似乎perform_sync没有触发。如果我将require'sidekiq/testing';Sidekiq::Testing.inline!添加到sidekiq.rb,它会按照我的预期记录并引发错误。我错过了什么吗?ruby2.3.0rails5.0.2Sidekiq4.2.9Redis3.2.0sidekiq.rbREDIS_URL='localhost'REDIS_PORT='6379'Sidekiq.configure_serverdo|co

Python async redis 给出错误 AttributeError : __aexit__

我是Python的新手,正在尝试构建一个简单的应用程序来从Redis数据库中检索数据。但是,当我尝试检索数据时,出现“AttributeError:__aexit_”错误。有人知道我做错了什么吗?提前致谢!我的代码:fromsanicimportSanicfromsanic.responseimportjsonimportredisapp=Sanic()#request.args['token']@app.route('/')asyncdeftest(request,id):asyncwithredis.StrictRedis(host='0.0.0.0',port=6379,db=0

asynchronous - 尝试使用 async.concat 从 redis 检索数据时出错

我正在关注异步作者here发布的示例但我收到了一个错误。redis-2.2.12Nodev0.4.11-pre这是我的代码:varasync=require('async');varredis=require('redis');varkeys=['key1','key2','key3'];varclient=redis.createClient();varmulti=client.multi();for(varkeyinkeys){multi.hmset(key,{'some':'value'});}multi.exec(function(err,res){if(err)thrower

mysql - 在 Spring 应用程序的事务中使用 Async

我有一个Spring应用程序,它使用@Transactional更新MySQL数据库中的特定实体详细信息方法,在同一方法中,我尝试使用@Async调用另一个端点这是另一个Spring应用程序,它从MySql数据库读取相同的实体并更新redis存储中的值。现在的问题是,每次我更新实体的一些值时,有时它会在Redis中更新,有时却不会。当我尝试调试时,我发现有时第二个应用程序在从MySql读取实体时会选择旧值而不是更新值。谁能建议我如何避免这种情况并确保第二个应用程序始终从Mysql中选择该实体的更新值? 最佳答案 M.Deinum的回

javascript - Mongoose 保存在 async.each 中创建重复项

我用异步处理了一个数组来保存和验证数据。这是我正在处理的:varguests=[{"email":"first@email.com","name":"Firstguest"},{"email":"second@email.com","name":"Secondguest"}];我正在遍历这个数组并一个一个地保存结果,但是如果我有多个客人,它会在我的mongoose文档中创建重复项。我该如何防止呢?这是处理客人的代码:Posts.findOne({'_id':req.params.id},function(err,post){async.each(guests,function(gues

ios - 图像持久化和延迟加载与 Dispatch_Async 冲突

我正在开发一个提要阅读器,我是通过使用nsxmlparser解析rss提要来实现的。我还有从CDATAblock中获取的缩略图对象。-(void)parser:(NSXMLParser*)parserfoundCDATA:(NSData*)CDATABlock{dispatch_async(dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT,0),^{NSString*someString=[[NSStringalloc]initWithData:CDATABlockencoding:NSUTF8StringEncodin

ios - 为什么使用 dispatch_async 比完全不使用它要慢?

我想知道为什么我的代码在使用dispatch_async时比完全不使用它时运行得慢得多。我试图通过屏蔽它并使用UIGraphicsImageRenderer来模糊我的UIImage的边缘(不确定它是否是最有效的方法..)但是当我不使用dispatch_async时,它运行得更快。这是为什么?这是我的代码和我从代码中得到的结果。非常感谢任何帮助。self.view.backgroundColor=[UIColorwhiteColor];dispatch_async(dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT,0),^

iphone - objective-c/iOS : setting status text in async function is slow

在我的应用程序中,我正在与远程服务器进行一些通信,由于这可能很慢,我认为异步运行该代码是个好主意。我在传递给dispatch_async的block中有我的通信代码。此代码进行通信,完成后设置标签文本。最后一部分是问题所在。文本已设置,但它会在几秒钟的延迟后出现。这是我的代码。-(void)doNetworkingTask{dispatch_async(dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT,0),^{//Slownetworktaskgoeshere.//Slownetworktaskdone,notifyt

iOS:dispatch_async 和 UIImageWriteToSavedPhotosAlbum

刚刚学习如何在线程之间分配任务,或者异步调度。我知道任何“接触”View的操作都必须在主线程上完成。怎么样:UIImageWriteToSavedPhotosAlbum?我假设这可以在后台线程上完成,但我错了吗?此外,如果它应该在后台线程上完成,下面这两个调用之间是否有区别,一个保存UIImage,另一个保存View中的UIImage?UIImageWriteToSavedPhotosAlbum(_someUIImage,nil,nil,nil);UIImageWriteToSavedPhotosAlbum(_imageView.image,nil,nil,nil);顺便说一下,我正在