counter_safe

example branch parameter

GitHub release

Thread safe counters:

Based on and with much thanks to: Comparing Crystal’s concurrency with that of Go (Part II)

Installation

  1. Add the dependency to your shard.yml:
dependencies:
  counter_safe:
    github: drhuffman12/counter_safe
  1. Run shards install ... or shards install --ignore-crystal-version

Usage

require "counter_safe"

Example Usage:

cs1 = CounterSafe::Shared.new
cs2 = CounterSafe::Shared.new
(1..1000).each {
  rand < 0.25 ? spawn cs1.inc("someKey") : spawn cs2.inc("someKey")
}

sleep 1.second
puts cs1.value("someKey")
puts cs2.value("someKey") #=> Should be the same as 'cs1.value("someKey")'
ce1 = CounterSafe::Exclusive.new
ce2 = CounterSafe::Exclusive.new
(1..1000).each {
  rand < 0.25 ? spawn ce1.inc("someKey") : spawn ce2.inc("someKey")
}
puts ce1.value("someKey")
puts ce2.value("someKey") #=> Should be DIFFERENT than as 'cs1.value("someKey")'

See also API doc's at: https://drhuffman12.github.io/counter_safe

Development

REMINDER: Be sure to do separate PR's for: (a) one or more PR(s) for 'regular' src/spec changes

# misc changes, then (before pushing your changes) run:
scripts/reformat
crystal spec

(b) followed by one PR for version bump and update docs

# bump version in `shards.yml`, then (before pushing your changes) run:
scripts/regen_docs

Contributing

  1. Fork it (https://github.com/your-github-user/counter_safe/fork)
  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. Create a new Pull Request

Contributors