草庐IT

EM_SETMARGINS

全部标签

ruby - 更好地使用 EM.next_tick 或 EM.defer 来使用 Eventmachine 进行长时间运行的计算?

当涉及到我必须自己实现的长时间运行的计算时,我正在尝试弄清楚如何使用可延迟对象。对于我的示例,我想计算前200000个斐波那契数,但只返回某个数。我对deferrable的第一次尝试是这样的:classFibAincludeEM::Deferrabledefcalcm,nfibs=[0,1]i=0do_work=proc{puts"DeferredThread:#{Thread.current}"ifi才意识到一切似乎都工作得很好,但是deferrable运行的线程与reactor线程相同(知道一切都在一个系统线程内运行,除非使用rbx或jruby)。所以我想出了第二次尝试,这对我来说

ruby - EventMachine WebSockets - 订阅 EM channel 与保持套接字在集合中

我正在构建一个使用EM和WebSockets并涉及向订阅的客户端广播数据的项目。我想知道为什么人们更喜欢订阅一个websocket到一个channel,如下所示:EventMachine::WebSocket.start(:host=>"0.0.0.0",:port=>8080)do|ws|ws.onopen{sid=@channel.subscribe{|msg|ws.sendmsg}@channel.push"#{sid}connected!"ws.onmessage{|msg|@channel.push":#{msg}"}ws.onclose{@channel.unsubscri

ruby-on-rails - 捆绑安装:G​​em::RemoteFetcher::FetchError: SSL:...证书验证失败

在Windows中,升级到Rails时。4.1.0.beta1,bundleinstall使用gemminitest创建错误:Gem::RemoteFetcher::FetchError:SSL_connectreturned=1errno=0state=SSLv3readservercertificateB:certificateverifyfailed(https://s3.amazonaws.com/production.s3.rubygems.org/gems/minitest-5.2.1.gem)之前发生过类似的错误,我们通常通过尝试安装旧版本来解决。但是这次minitest

ruby - EventMachine 和 em-websocket - 从队列中读取并推送到 channel

我正在使用eventmachine读取HornetQ主题,推送到由EMwebsocket连接订阅的channel。我需要防止@topic.receive循环阻塞,所以创建了一个proc并在没有回调的情况下调用EventMachine.defer。这将无限期地运行。这很好用。我也可以只使用Thread.new。我的问题是,这是从流/队列中读取并将数据传递到channel的正确方法吗?是否有更好的/任何其他方法来执行此操作?require'em-websocket'require'torquebox-messaging'classWebsocketServerdefinitialize@c

ruby - 运行错误 'requirements_osx_brew_update_system ' ,

当我尝试$rvmrequirements我得到了错误:如何从此恢复(Macosx10.7)Checkingrequirementsforosx.Installingrequirementsforosx.Updatingsystem.......Errorrunning'requirements_osx_brew_update_system',pleaseread/Users/HARSHA/.rvm/log/1380096954/update_system.logRequirementsinstallationfailedwithstatus:1.HARSHA:~HARSHA$rvmre

Ruby EventMachine - 如何将值从 EM::Deferrable 返回到主 EM 循环?

我现在正在使用EventMachine玩了几天,恕我直言,它的学习曲线很陡;-)我尝试通过触发回调中需要的HttpHeaderCrawler.query()来返回哈希。但是在这种情况下我得到的不是散列{'http_status'=>xxx,'http_version'=>xxx}而是一个EventMachine::HttpClient对象本身。我想保持EM.runblock干净,并想在自己的类/模块中执行所有逻辑,那么如何将这样的值返回到主循环中以通过回调访问它?非常感谢;-)#!/usr/bin/envrubyrequire'eventmachine'require'em-http-

ruby - 如何使用 em_mysql2 解决 'connection is still waiting for a result' 错误

我在Goliath(eventmachine)下使用activerecord和em_mysql2。最奇怪的事情发生在我的用户模型上。当我第一次对/users进行POST时,一切正常,就像预期的那样。当我执行第二个POST时出现错误。Mysql2::Error:Thisconnectionisstillwaitingforaresult,tryagainonceyouhavetheresult:INSERTINTO`users`(...andsoon...)我的任何其他模型或路线都不会发生这种情况。我会假设如果数据库连接处于困惑状态,我会在其他请求上看到相同的错误,但不会-所有其他数据库

ruby - EM::Iterator 的工作示例

有人有任何EM::Iterator的工作示例吗?我能找到的唯一示例似乎是(或指向)的副本:http://yardoc.org/docs/eventmachine-eventmachine/EventMachine/Iterator我在EventMachine的Rdoc中没有看到EM::Iterator的任何实例,所以我不确定它是否是一个已被删除的旧类。当我尝试使用EM::Iterator时,我通常会遇到以下错误:NameError:未初始化的常量EventMachine::Iterator谢谢! 最佳答案 问题是最新发布的Event

【机器学习】EM原理和K-mean聚类

一、教程说明        EM算法就是expectmaxmise算法,就是“期望最大化”的缩写。本篇首先提出:1什么是期望?2期望最大化是个啥意思?k-mean聚类中如何用EM算法? 所涉及的概念: 期望 期望的加权平均理解 概率模型和统计模型 期望最大化 k-mean算法的原理二、什么是期望?2.1从一个思想实验入门        在回答这个概念之前,我们可以做一个思想实验。        假如:我们这里有一枚六面骰子        1)每次掷出“1”奖励一块钱,那么掷出100次,您能得到几块钱?        我们很容易想到:掷出100次,获得“1”的次数大约100/6次,每次的1块,总

【机器学习】EM原理和K-mean聚类

一、教程说明        EM算法就是expectmaxmise算法,就是“期望最大化”的缩写。本篇首先提出:1什么是期望?2期望最大化是个啥意思?k-mean聚类中如何用EM算法? 所涉及的概念: 期望 期望的加权平均理解 概率模型和统计模型 期望最大化 k-mean算法的原理二、什么是期望?2.1从一个思想实验入门        在回答这个概念之前,我们可以做一个思想实验。        假如:我们这里有一枚六面骰子        1)每次掷出“1”奖励一块钱,那么掷出100次,您能得到几块钱?        我们很容易想到:掷出100次,获得“1”的次数大约100/6次,每次的1块,总