Module: Rubu::MoveStyles

Included in:

Step, Trail

Defined in:

lib/rubu.rb

Overview

Trail/Step execution styles.

Instance Method Summary

• #parallel_run ⇒ Object

  Run @subs in parallel (unless serial is forced).

• #serial_run ⇒ Object

  Run @subs in sequence.

Instance Method Details

#parallel_run ⇒ Object

Run @subs in parallel (unless serial is forced).

# File 'lib/rubu.rb', line 211

def parallel_run

    if Order[ :serial ]

        serial_run

    else

        if Order[ :parmax ] == 0 || @subs.length < Order[ :parmax ]

            ths = []
            @subs.each do |item|
                ths.push(
                    Thread.new do
                        item.run
                    end
                    )
            end
            ths.each do |th|
                th.join
            end

        else

            cnt = @subs.length
            done = 0
            while done < cnt

                incr = Order[ :parmax ]
                if done >= cnt
                    incr = done - cnt
                end

                ths = []
                incr.times do |i|
                    item = @subs[ done+i ]
                    ths.push(
                        Thread.new do
                            item.run
                        end
                        )
                end
                ths.each do |th|
                    th.join
                end

                done += incr
            end

        end

        @subs.each do |item|
            if item.status == :error
                @status = :error
                @errmsg = item.errmsg
                break
            end
        end

        self
    end
end

#serial_run ⇒ Object

Run @subs in sequence.

# File 'lib/rubu.rb', line 197

def serial_run
    @subs.each do |sub|
        sub.run
        if sub.status == :error
            @status = :error
            @errmsg = sub.errmsg
            break
        end
    end

    self
end