module FaaStRuby
  class ConcurrencyController
    def self.store
      @@store ||= {} 
    end
    attr_accessor :params, :name, :max, :type
    def initialize(name, max: 1, type:)
      @type = type
      @name = name
      @max = max
      @running = 0
      # @mutex = Mutex.new
      self.class.store[name] = self
      puts "[ConcurrencyController] Started controller for '#{name}' with max_concurrency = #{@max}".yellow
    end
  
    def running
      # puts "[ConcurrencyController] [#{name}] Reading runners".red
      # wait
      # puts "[ConcurrencyController] [#{name}] Locking mutex".red
      # @mutex.lock
      @running
    # ensure
      # puts "[ConcurrencyController] [#{name}] Unlocking mutex".red
      # @mutex.unlock
    end

    def decr(amount = 1)
      incr(0 - amount)
    end
  
    def incr(amount = 1)
      # puts "[ConcurrencyController] [#{name}] Incr #{amount}".red
      # wait
      # puts "[ConcurrencyController] [#{name}] Locking mutex".red
      # @mutex.lock
      current = @running + amount
      return nil if max < current
      @running += amount
    # ensure
    #   puts "[ConcurrencyController] [#{name}] Unlocking mutex".red
    #   @mutex.unlock
    end
  
    # def wait
    #   puts "[ConcurrencyController] [#{name}] Waiting for mutex lock to release".red
    #   while @mutex.locked? do;end
    #   puts "[ConcurrencyController] [#{name}] Mutex released".red
    # end
  end
end