1024cores - Case Study: MultiLane - a concurrent blocking multiset
This is about the MultiLane : a concurrent blocking multiset paper. Go and read it first, it's just 4 pages including references and an appendix. Ok, I did not expect that you do that anyway :) It describes a way to improve scalability of a producer-consumer system by means of partitioning. Basically, it presents a way to wrap any producer-consumer queue in order to get a queue with the same prope
POE::Component::JobQueue
NAME POE::Component::JobQueue - a component to manage queues and worker pools SYNOPSIS use POE qw(Component::JobQueue); # Passive queue waits for enqueue events. POE::Component::JobQueue->spawn ( Alias => 'passive', # defaults to 'queuer' WorkerLimit => 16, # defaults to 8 Worker => \&spawn_a_worker, # code which will start a session Passive => { Prioritizer => \&job_comparer, # defaults to sub {
Q4M - a Message Queue for MySQL
Q4M (Queue for MySQL) is a message queue licensed under GPL that works as a pluggable storage engine of MySQL, designed to be robust, fast, flexible. It is already in production quality, and is used by several web services (see Users of Q4M). To start using Q4M, download either a binary or source distribution from the install page, and follow the installation instructions. A small tutorial is also
Kazuho@Cybozu Labs: Q4M - MySQL 上で動作するメッセージキュー
« ウェブアプリケーションにおけるHDDの正しい使い方 | メイン | Pathtraq リニューアルのおしらせ (リアルタイム検索機能の追加ほか) » 2008年01月15日 Q4M - MySQL 上で動作するメッセージキュー 数年来ずっと「RDBMSに統合されたメッセージキューがほしい」と言ってきたわけですが、昨年末にストレージエンジンをプラグインとして開発できる MySQL 5.1 が RC になっていることに気づき、自分で作ってみました。 Q4M (Queue for MySQL) は MySQL 5.1 のプラガブル・ストレージ・エンジンとして動作するメッセージキューであり、堅牢・高速・柔軟であるよう設計されています。昨年12月遅くに開発が開始され、まだ非常に原始的ですが、かなり高速に動作します。 q4m.31tools.com 自分の英語を日本語訳するというのも変なものですが
メッセージキュー事始め in Ruby (nakatani @ cybozu labs)
ruby でメッセージキューを扱いたく、stomp クライアントライブラリを試してみました。 って、奥さんのエントリとシンクロしているようですが、気のせいではありません(笑)。 1. メッセージキューを起動 ruby の stomp はクライアントだけなので、キュー(サーバ側) は ActiveMQ を使うか、Perl の POE::Component::MessageQueue で立てる必要があります。 今回は奥さんとのメッセージのやりとりが目標なので、奥さんのプログラム( POE::Component::MessageQueue 使用)をそのまま使わせてもらいました。 /usr/bin/mq.pl --data-dir /tmp/mq プチTIPS: POE::Component::MessageQueue でキューを立てて、subscribe したり、subscribe されていない
IPC::DirQueue
NAME IPC::DirQueue - disk-based many-to-many task queue SYNOPSIS my $dq = IPC::DirQueue->new({ dir => "/path/to/queue" }); $dq->enqueue_file("filename"); my $dq = IPC::DirQueue->new({ dir => "/path/to/queue" }); my $job = $dq->pickup_queued_job(); if (!$job) { print "no jobs left\n"; exit; } # ...do something interesting with $job->get_data_path() ... $job->finish(); DESCRIPTION This module implem
1
リリース、障害情報などのサービスのお知らせ
最新の人気エントリーの配信
処理を実行中です
j次のブックマーク
k前のブックマーク
lあとで読む
eコメント一覧を開く
oページを開く
