chore: add benchmark and profiling scripts

Author: ffloyd

.gitignore

@@ -9,3 +9,7 @@
 
 # rspec failure tracking
 .rspec_status
+
+# profile results folder
+/profile/
+!/profile/.keep

Gemfile.lock

@@ -7,13 +7,39 @@ GEM
   remote: https://rubygems.org/
   specs:
     ast (2.4.0)
+    benchmark-ips (2.7.2)
     codecov (0.1.14)
       json
       simplecov
       url
     coderay (1.1.2)
+    concurrent-ruby (1.1.5)
     diff-lcs (1.3)
     docile (1.3.1)
+    dry-configurable (0.8.3)
+      concurrent-ruby (~> 1.0)
+      dry-core (~> 0.4, >= 0.4.7)
+    dry-container (0.7.2)
+      concurrent-ruby (~> 1.0)
+      dry-configurable (~> 0.1, >= 0.1.3)
+    dry-core (0.4.9)
+      concurrent-ruby (~> 1.0)
+    dry-equalizer (0.2.2)
+    dry-events (0.2.0)
+      concurrent-ruby (~> 1.0)
+      dry-core (~> 0.4)
+      dry-equalizer (~> 0.2)
+    dry-matcher (0.8.1)
+      dry-core (>= 0.4.7)
+    dry-monads (1.3.0)
+      concurrent-ruby (~> 1.0)
+      dry-core (~> 0.4, >= 0.4.4)
+      dry-equalizer
+    dry-transaction (0.13.0)
+      dry-container (>= 0.2.8)
+      dry-events (>= 0.1.0)
+      dry-matcher (>= 0.7.0)
+      dry-monads (>= 0.4.0)
     jaro_winkler (1.5.2)
     json (2.2.0)
     method_source (0.9.2)
@@ -51,29 +77,41 @@ GEM
       rubocop (>= 0.58.0)
     rubocop-rspec (1.32.0)
       rubocop (>= 0.60.0)
+    ruby-prof (1.0.0)
     ruby-progressbar (1.10.0)
     simplecov (0.16.1)
       docile (~> 1.1)
       json (>= 1.8, < 3)
       simplecov-html (~> 0.10.0)
     simplecov-html (0.10.2)
+    trailblazer-activity (0.8.4)
+      trailblazer-context (>= 0.1.4)
+    trailblazer-activity-dsl-linear (0.1.8)
+      trailblazer-activity (>= 0.8.3, < 1.0.0)
+    trailblazer-context (0.1.4)
+    trailblazer-operation (0.5.2)
+      trailblazer-activity-dsl-linear (>= 0.1.6, < 1.0.0)
     unicode-display_width (1.5.0)
     url (0.3.2)
 
 PLATFORMS
   ruby
 
 DEPENDENCIES
+  benchmark-ips
   bundler (~> 2.0)
   codecov
+  dry-transaction
   flows!
   pry
   rake (~> 10.0)
   rspec (~> 3.0)
   rubocop
   rubocop-performance
   rubocop-rspec
+  ruby-prof
   simplecov
+  trailblazer-operation
 
 BUNDLED WITH
    2.0.1

bin/benchmark

@@ -0,0 +1,88 @@
+#!/usr/bin/env ruby
+# rubocop:disable all
+
+require 'bundler/setup'
+require 'benchmark/ips'
+
+require_relative './examples'
+
+puts '-' * 50
+puts '- task: A + B, one step implementation'
+puts '-' * 50
+
+flows_summator = FlowsSummator.new
+dry_summator = DrySummator.new
+
+Benchmark.ips do |b|
+  b.report 'Flows::Operation (build each time)' do
+    FlowsSummator.new.call(a: 1, b: 2)
+  end
+
+  b.report 'Flows::Operation (build once)' do
+    flows_summator.call(a: 1, b: 2)
+  end
+
+  unless ENV['FLOWS_ONLY']
+    b.report 'Dry::Transaction (build each time)' do
+      DrySummator.new.call(a: 1, b: 2)
+    end
+
+    b.report 'Dry::Transaction (build once)' do
+      dry_summator.call(a: 1, b: 2)
+    end
+
+    b.report 'Trailblazer::Operation' do
+      TBSummator.call(a: 1, b: 2)
+    end
+  end
+
+  if ENV['WITH_PORO']
+    b.report 'PORO' do
+      POROSummator.call(a: 1, b: 2)
+    end
+  end
+
+  b.compare!
+end unless ENV['SKIP_SUM']
+puts
+
+
+puts '-' * 50
+puts '- task: ten steps returns successful result'
+puts '-' * 50
+
+flows_ten_steps = FlowsTenSteps.new
+dry_ten_steps = DryTenSteps.new
+
+Benchmark.ips do |b|
+  b.report 'Flows::Operation (build each time)' do
+    FlowsTenSteps.new.call(a: 1, b: 2)
+  end
+
+  b.report 'Flows::Operation (build once)' do
+    flows_ten_steps.call(a: 1, b: 2)
+  end
+
+  unless ENV['FLOWS_ONLY']
+    b.report 'Dry::Transaction (build each time)' do
+      DryTenSteps.new.call(a: 1, b: 2)
+    end
+
+    b.report 'Dry::Transaction (build once)' do
+      dry_ten_steps.call(a: 1, b: 2)
+    end
+
+    b.report 'Trailblazer::Operation' do
+      TBTenSteps.call(a: 1, b: 2)
+    end
+  end
+
+  if ENV['WITH_PORO']
+    b.report 'PORO' do
+      POROTenSteps.call
+    end
+  end
+
+  b.compare!
+end unless ENV['SKIP_10']
+puts

bin/examples.rb

@@ -0,0 +1,159 @@
+# rubocop:disable all
+require 'flows'
+require 'dry/transaction'
+require 'trailblazer/operation'
+
+#
+# Task: a + b = ?
+#
+
+class FlowsSummator
+  include Flows::Operation
+
+  step :sum
+
+  success :sum
+
+  def sum(a:, b:, **)
+    ok(sum: a + b)
+  end
+end
+
+class POROSummator
+  def self.call(a:, b:)
+    a + b
+  end
+end
+
+class DrySummator
+  include Dry::Transaction
+
+  step :sum
+
+  private
+
+  def sum(a:, b:)
+    Success(a + b)
+  end
+end
+
+class TBSummator < Trailblazer::Operation
+  step :sum
+
+  def sum(opts, a:, b:, **)
+    opts[:sum] = a + b
+  end
+end
+
+#
+# Task: 10 steps which returs simple value
+#
+
+class FlowsTenSteps
+  include Flows::Operation
+
+  step :s1
+  step :s2
+  step :s3
+  step :s4
+  step :s5
+  step :s6
+  step :s7
+  step :s8
+  step :s9
+  step :s10
+
+  success :data
+
+  def s1(**); ok(s1: true); end
+  def s2(**); ok(s2: true); end
+  def s3(**); ok(s3: true); end
+  def s4(**); ok(s4: true); end
+  def s5(**); ok(s5: true); end
+  def s5(**); ok(s5: true); end
+  def s6(**); ok(s6: true); end
+  def s7(**); ok(s7: true); end
+  def s8(**); ok(s8: true); end
+  def s9(**); ok(s9: true); end
+  def s10(**); ok(data: :ok); end
+end
+
+class POROTenSteps
+  class << self
+    def call()
+      s1
+      s2
+      s3
+      s4
+      s5
+      s6
+      s7
+      s8
+      s9
+      s10
+    end
+
+    def s1; true; end
+    def s2; true; end
+    def s3; true; end
+    def s4; true; end
+    def s5; true; end
+    def s6; true; end
+    def s7; true; end
+    def s8; true; end
+    def s9; true; end
+    def s10; true; end
+  end
+end
+
+class DryTenSteps
+  include Dry::Transaction
+
+  step :s1
+  step :s2
+  step :s3
+  step :s4
+  step :s5
+  step :s6
+  step :s7
+  step :s8
+  step :s9
+  step :s10
+
+  private
+
+  def s1; Success(true); end
+  def s2; Success(true); end
+  def s3; Success(true); end
+  def s4; Success(true); end
+  def s5; Success(true); end
+  def s6; Success(true); end
+  def s7; Success(true); end
+  def s8; Success(true); end
+  def s9; Success(true); end
+  def s10; Success(true); end
+end
+
+class TBTenSteps < Trailblazer::Operation
+  step :s1
+  step :s2
+  step :s3
+  step :s4
+  step :s5
+  step :s6
+  step :s7
+  step :s8
+  step :s9
+  step :s10
+
+  def s1(opts, **); opts[:s1] = true; end
+  def s2(opts, **); opts[:s2] = true; end
+  def s3(opts, **); opts[:s3] = true; end
+  def s4(opts, **); opts[:s4] = true; end
+  def s5(opts, **); opts[:s5] = true; end
+  def s6(opts, **); opts[:s6] = true; end
+  def s7(opts, **); opts[:s7] = true; end
+  def s8(opts, **); opts[:s8] = true; end
+  def s9(opts, **); opts[:s9] = true; end
+  def s10(opts, **); opts[:s10] = true; end
+end

bin/profile_10steps

@@ -0,0 +1,28 @@
+#!/usr/bin/env ruby
+# rubocop:disable all
+
+require 'bundler/setup'
+require 'ruby-prof'
+
+require_relative './examples'
+
+puts 'Profile building...'
+result = RubyProf.profile do
+  10_000.times do
+    FlowsTenSteps.new
+  end
+end
+printer = RubyProf::MultiPrinter.new(result)
+printer.print(path: 'profile', profile: '10steps_build_10k_times')
+
+
+flows_ten_steps = FlowsTenSteps.new
+
+puts 'Profile execution...'
+result = RubyProf.profile do
+  10_000.times {
+    flows_ten_steps.call
+  }
+end
+printer = RubyProf::MultiPrinter.new(result)
+printer.print(path: 'profile', profile: '10steps_execution_10k_times')

bin/ruby_benchmarks

@@ -0,0 +1,26 @@
+#!/usr/bin/env ruby
+# rubocop:disable all
+
+require 'bundler/setup'
+require 'benchmark/ips'
+
+puts '-' * 50
+puts '- method execution'
+puts '-' * 50
+
+class OneMethod
+  def meth
+    :ok
+  end
+end
+
+one_method = OneMethod.new
+method_obj = one_method.method(:meth)
+
+Benchmark.ips do |b|
+  b.report('native call') { one_method.meth }
+  b.report('send(...)') { one_method.send(:meth) }
+  b.report('Method#call') { method_obj.call }
+
+  b.compare!
+end