No commit activity in last 3 years
No release in over 3 years
A process synchronisation module for Ruote.
2005
2006
2007
2008
2009
2010
2011
2012
2013
2014
2015
2016
2017
2018
2019
2020
2021
2022
2023
2024
 Dependencies

Development

~> 1.3
>= 0
>= 0

Runtime

>= 0
 Project Readme

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

Changelog

  • April 29, 2013: 0.1.0 release
    • Initial release