Nic*_*ite 12 ruby concurrency logging asynchronous
同步日志记录会因为可能阻塞而导致性能损失.是否有一个独立的Ruby库来执行异步日志记录(log4r似乎不是)?我可以修改标准库记录器以异步记录吗?我正在寻找像log4j的AsyncAppender这样的东西 - 但最好是利用Ruby的代码块将尽可能多的工作转移到后台线程的实现.
Nic*_*ite 15
我知道你不应该真正回答你自己的问题,但看起来ruby中的一切都很简单:
require 'thread'
require 'singleton'
require 'delegate'
require 'monitor'
class Async
include Singleton
def initialize
@queue = Queue.new
Thread.new { loop { @queue.pop.call } }
end
def run(&blk)
@queue.push blk
end
end
class Work < Delegator
include MonitorMixin
def initialize(&work)
super work; @work, @done, @lock = work, false, new_cond
end
def calc
synchronize {
@result, @done = @work.call, true;
@lock.signal
}
end
def __getobj__
synchronize { @lock.wait_while { !@done } }
@result
end
end
Module.class.class_exec {
def async(*method_names)
method_names.each do |method_name|
original_method = instance_method(method_name)
define_method(method_name) do |*args,&blk|
work = Work.new { original_method.bind(self).call(*args,&blk) }
Async.instance.run { work.calc }
return work
end
end
end
}
Run Code Online (Sandbox Code Playgroud)
对于我的日志示例:
require 'Logger'
class Logger
async :debug
end
log = Logger.new STDOUT
log.debug "heloo"
Run Code Online (Sandbox Code Playgroud)
由于返回值有效,您可以将它用于任何事情:
require "test/unit"
class ReturnValues < Test::Unit::TestCase
def do_it
5 + 7
end
async :do_it
def test_simple
assert_equal 10, do_it - 2
end
end
Run Code Online (Sandbox Code Playgroud)