草庐IT

守护线程

全部标签

ruby - 将电子邮件组织成线程的算法?

是否有任何命名/著名/特别好的算法来将电子邮件消息组织到线程中?我想在我的网站上添加一个类似于Google网上论坛(和其他邮寄列表)的功能,我只是想知道是否有任何已发布的此类组织算法。我知道推出我自己的算法可能相当容易,但可通过的算法和良好的算法之间的用户体验可能存在很大差异。已在ruby​​中实现的算法的奖励积分! 最佳答案 jwz_threading看起来正是您要的。我没用过。 关于ruby-将电子邮件组织成线程的算法?,我们在StackOverflow上找到一个类似的问题:

ruby - 为什么 EventMachine 的延迟比 Ruby 线程慢?

我有两个使用Mechanize获取Google索引页的脚本。我原以为EventMachine会比Ruby线程更快,但事实并非如此。EventMachine代码成本:“0.24s用户0.08s系统2%cpu12.682总计”Ruby线程代码成本:“0.22s用户0.08s系统5%cpu5.167总计”我是否以错误的方式使用了EventMachine?事件机器:require'rubygems'require'mechanize'require'eventmachine'trap("INT"){EM.stop}EM.rundonum=0operation=proc{agent=Mechan

ruby - Ruby 的 Net::HTTP 线程安全吗?

Ruby的Net::HTTP线程安全吗?(除了它明确表示不是的version_1_1和version_1_2方法) 最佳答案 我不会指望它。2008年,matzwrote:ForMRI(1.8.x)andYARV(1.9.x),everyCimplementedmethodsareprotectedbyGIL(GlobalInterpreterLock),sothatyoudon'thavetoworryabout.Butitmightdependoneachimplementation.Net::HTTP在stdlib中,这意味着

ruby - Ruby 的线程组有什么用?

我正在浏览Pickaxe,寻找有关Thread的文档,并遇到了ThreadGroup。文档描述了它的作用,但没有解释它的用途。是与线程池相关的线程组,我assumedRubydoesn'thave? 最佳答案 新线程在其父线程组中创建。您可以使用ThreadGroup组织由产生其他线程的父线程给出的隐式树结构,并使用list实例方法获取所有尚未终止的线程,即定义对所有线程进行操作的方法组中的线程。此外,如果您运行不受信任的代码并希望关注它产生的线程,您可以使用enclose来禁止向该组添加(或删除)线程。

ruby - 使用 Puma 的工作线程、线程和池大小

如果我有一台只有1个核心的服务器,多少个pumaworker、线程和多少数据库池大小才合适?这里的一般拇指是什么? 最佳答案 这不是一个简单的答案。信息的两个主要来源是:Pumagithubrepository(作者的观点)Heroku'swebpage(主要大用户观点)不幸的是,它们不一致主要是因为heroku具有不同的部署指标和术语。所以我最终遵循了puma存储库指南,其中写道:每个核心一个worker要根据RAM可用性和应用程序确定线程线程=连接池所以线程数多半是试探操作。 关于r

ruby - 如何计算ruby服务器中正在运行的线程

我想在Sinatra网络服务器的线程中执行“长时间运行”-(执行大约需要0.5秒)任务。Web响应大约需要20毫秒,所以如果我很忙,线程就会堆积起来......所以我想如果我忙的话我会同步..if(running_thread_count>10)stuff_that_takes_a_second()elseThread.newdostuff_that_takes_a_second()endend您如何获得正在运行的线程数(我想要启动的线程数,但尚未完成运行)-您如何编写running_thread_count代码?defrunning_thread_countreturnThread.

线程池七个参数的含义

说一下线程池七个参数的含义?所谓的线程池的7大参数是指,在使用ThreadPoolExecutor创建线程池时所设置的7个参数,如以下源码所示:publicThreadPoolExecutor(intcorePoolSize,intmaximumPoolSize,longkeepAliveTime,TimeUnitunit,BlockingQueueworkQueue,ThreadFactorythreadFactory,RejectedExecutionHandlerhandler){}这7个参数分别是:corePoolSize:核心线程数。maximumPoolSize:最大线程数。kee

多线程问题:为什么不应该使用多线程读写同一个socket连接?

问题的产生经典的单reactor多线程模式采用的是用主线程处理连接事件以及socket读写事件,业务逻辑的处理则是让线程池里的线程各自竞争处理。既然多线程这么方便,为什么不让线程池里的线程也参与到read和send这个过程中呢?在发送数据的过程中,即使TCP的发送缓存满了,我们也可以记录下当前成功发送了多少字节,然后再次注册一个EPOLLOUT事件,只需等待下次可写事件,继续让子线程发送数据即可,岂不是美哉?解释陈硕大佬的解释对于TCP,通常多线程读写同一个socket是错误的设计,因为有shortwrite的可能。假如你加锁,而又发生shortwrite,你是不是要一直等到整条消息发送完才解

ruby - ruby 一次可以运行的线程数是否有限制?

如果不是,那么在保持高效的情况下,最大值是多少?我正在创建14个线程,每个线程都会打开一个URL列表(大约500个),为每个线程创建一个新线程,然后下载它,并将其添加到MySQL数据库中。MySQL池大小设置为50。这是RoR中的一个rake任务。使用Kernal#fork或其他方法会更好吗? 最佳答案 require'open-uri'a='http://www.example.com'*30arr=a.split('')arr.each_slice(3)do|group|group.mapdo|site|Thread.newdo

ruby - 如何从 ruby​​ 线程获取错误消息

我现在遇到了一个问题,我无法看到我的子线程在哪里吐出错误消息,这使得调试变得困难。例如:Thread.new{a=1/0}有什么方法可以在标准错误中打印出所有线程错误吗? 最佳答案 将Thread类的abort_on_exception标志设置为true。或者,将线程主体包裹在throw/catchblock中,并将异常转储到catch中。 关于ruby-如何从ruby​​线程获取错误消息,我们在StackOverflow上找到一个类似的问题: https:/