jjzjj

worker_thread

全部标签

ruby-on-rails - 可以在 Thread::handle_interrupt block 之外异步处理 ruby​​ 异常吗?

乍一看,我以为新的ruby​​2.0Thread.handle_interrupt会解决我所有的异步中断问题,但除非我弄错了,否则我无法让它做我想做的事(我的问题在最后和标题中)。从文档中,我可以看到如何避免在某个block中接收中断,将它们推迟到另一个block。这是一个示例程序:duration=ARGV.shift.to_it=Thread.newdoThread.handle_interrupt(RuntimeError=>:never)do5.times{putc'-';sleep1}Thread.handle_interrupt(RuntimeError=>:immedia

ruby - Thread#run 和 Thread#wakeup 之间的区别?

在Ruby中,Thread#run和Thread#wakup有什么区别?RDoc指定scheduler不使用Thread#wakeup调用,但这是什么意思?何时使用唤醒与运行的示例?谢谢。编辑:我看到Thread#wakup导致线程变为可运行状态,但如果在执行Thread#run之前它不会执行(无论如何都会唤醒线程),它有什么用?有人可以提供一个示例,其中wakeup做了一些有意义的事情吗?出于好奇=) 最佳答案 这里有一个例子来说明它的含义(来自here的代码示例):线程唤醒thread=Thread.newdoThread.st

ruby-on-rails - 使用 worker 启动 Puma 服务器时出错

我是Rails和Puma的新手,所以这个问题对于简单的解决方案来说可能太愚蠢了,如果您认为我做错了什么,也请指导我。我正在尝试与工作人员一起为我的Rails启动Puma服务器。如果我将workers设置为0puma-w0服务器完美启动,但如果我将worker设置为1或更多,则会出现以下错误:E:\RoR_tryouts\ws_13.11.13\todo>puma-w3[2120]***SIGUSR2notimplemented,signalbasedrestartunavailable![2120]***SIGUSR1notimplemented,signalbasedrestartu

Ruby 并发 : non-blocking I/O vs threads

我正在研究Ruby(1.9.3-p0)中的并发性,并创建了一个非常简单的I/O密集型代理任务。首先,我尝试了非阻塞方法:require'rack'require'rack/fiber_pool'require'em-http'require'em-synchrony'require'em-synchrony/em-http'proxy=lambda{|*|result=EM::Synchrony.syncEventMachine::HttpRequest.new('http://google.com').get[200,{},[result.response]]}useRack::Fi

ruby-on-rails - Resque multiple workers in development 模式

您好,在开发中可以同时运行多个Resqueworker吗?我找到了这段代码,但不确定它是否会工作以及如何工作..http://pastebin.com/9GKk8GwR到目前为止我使用的是标准bundleexecenvrakeresque:workQUEUE='*'redis-server/usr/local/etc/redis.conf 最佳答案 您需要添加一个COUNT环境变量,然后将resque:work更改为resque:workers。例如启动3个worker:bundleexecenvrakeresque:workers

ruby-on-rails - 登录 Sidekiq worker

我正在尝试在开发中使用tail-flog/development.log并在生产中使用herokulogs来记录我的sideqikworker的进度。但是,worker内部的所有内容以及worker调用的所有内容都不会被记录。在下面的代码中,仅记录TEST1。如何记录工作人员内部的所有内容以及工作人员调用的类?#app/controllers/TasksController.rbdefimport_dataRails.logger.info"TEST1"#showsupindevelopment.logDataImportWorker.perform_asyncrender"done"

ruby - 什么时候需要将参数传递给 `Thread.new` ?

在线程外部定义的局部变量似乎从内部可见,因此Thread.new的以下两种用法似乎是相同的:a=:fooThread.new{putsa}#=>:fooThread.new(a){|a|putsa}#=>:foodocument举个例子:arr=[]a,b,c=1,2,3Thread.new(a,b,c){|d,e,f|arr[1,2,3]但由于a、b、c在创建的线程内部是可见的,所以这也应该与:arr=[]a,b,c=1,2,3Thread.new{d,e,f=a,b,c;arr[1,2,3]有区别吗?什么时候需要将局部变量作为参数传递给Thread.new?

ruby - Thread.join 阻塞主线程

调用Thread.join会阻塞当前(主)线程。然而,当主线程退出时,不调用join会导致所有生成的线程被杀死。如何在不阻塞主线程的情况下在Ruby中生成持久性子线程?这是连接的典型用法。foriin1..100doputs"Creatingthread#{i}"t=Thread.new(i)do|j|sleep1puts"Thread#{j}done"endt.joinendputs"#{Thread.list.size}threads"这给出了Creatingthread1Thread1doneCreatingthread2Thread2done...1threads但是我正在寻找

system.threading.Timer每天尝试同时制作计时器

我在控制台服务应用中使用system.threading.timer,并尝试每天同时制作计时器。最初,如果我在时间之前启动该应用程序,我会很好。就像我的时间是10:05,我从10:00启动该应用程序,我们很好。但是,如果我从10:06开始,我就不知道如何告诉时间台下24小时。谢谢你的帮助!publicvoidSetUpTimer(TimeSpanalertTime){DateTimecurrent=DateTime.Now;TimeSpantimeToGo=alertTime-current.TimeOfDay;if(timeToGo{EventLog.WriteEntry("MhyApp",

ruby-on-rails - ruby/rails 中的 worker 是什么?

我来自Java世界,在ruby​​/rails世界中一直听到“worker”这个词。它是什么?一个线程? 最佳答案 取决于上下文。工作人员通常是在您的应用程序请求周期之外运行的进程。Ruby库,如resque和delayed_job通常用于管理工作队列。另一方面,如果我们谈论网络服务器,“worker”一词有时可与线程或进程互换使用(即:nginx或apache“workers”)。 关于ruby-on-rails-ruby/rails中的worker是什么?,我们在StackOverf