Build Status Coverage Status Code Climate Dependency Status

Ruote::Synchronize

Synopsis

A process synchronisation module for Ruote.

Will define a synchronize :key => "my_unique_key" participant. You can use it in two processes by defining the same synchronisation key. The first process to reach the synchronization will wait for the other one.

Usage


# Charly and Doug will only run when both Alice and Bob have run,
# no matter which one of Alice or Bob finishes first

Ruote::Synchronize.setup(engine)

pdef1 = Ruote.process_definition do
  alice
  synchronize :key => 'my_very_unique_key'
  charly
end

pdef2 = Ruote.process_definition do
  bob
  synchronize :key => 'my_very_unique_key'
  doug
end

It works by storing the first workitem along with the key. When the second process reaches synchronize, it will find the previous workitem, receive it (allowing the first process to proceed), and reply immediately.

You must use a key that you know will NEVER be used outside of the two process you want to synchronize.

Pay attention to multiple launches (if your process is launched by an HTTP request for example). If three processes with the same key are launched, the two first will be synchronized and the last one will be left hanging.

Requirements

A functionall installation of Ruote is needed.

ruote-synchronize has been tested on Ruby 1.8+.

Installation

Add this line to your application's Gemfile:

gem 'ruote-synchronize'

And then execute:

$ bundle

Or install it yourself as:

$ gem install ruote-synchronize

Contributing

  1. Fork it
  2. Create your feature branch (git checkout -b my-new-feature)
  3. Commit your changes (git commit -am 'Add some feature')
  4. Push to the branch (git push origin my-new-feature)
  5. Run the tests (bundle exec rspec)
  6. Create new Pull Request