Packages

poolex

0.8.0
1.6.4 1.6.3 1.6.2 1.6.1 1.6.0 1.5.0 1.5.0-rc.0 1.4.2 1.4.1 1.4.0 1.3.0 1.2.1 1.2.0 1.1.0 1.0.0 1.0.0-rc.0 0.10.0 0.9.0 0.9.0-rc.2 0.9.0-rc.1 0.9.0-rc.0 0.8.0 0.8.0-rc.1 0.8.0-rc.0 0.7.6 0.7.5 0.7.4 retired 0.7.3 0.7.2 0.7.1 0.7.0 0.6.1 0.6.0 0.5.1 0.5.0 0.4.0 0.3.1 retired 0.3.0 retired 0.2.2 0.2.1 0.2.0 0.1.1 0.1.0

The library for managing pools of workers.

HexDocs

Current section

Files

Jump to
Readme
43 Versions
0 Dependencies
Dependants
Files
Activity
poolex lib poolex private busy_workers.ex
Raw

lib/poolex/private/busy_workers.ex 

defmodule Poolex.Private.BusyWorkers do

  @moduledoc false



  alias Poolex.Private.State



  @doc false

  @spec init(State.t(), busy_workers_impl :: module()) :: State.t()

  def init(%State{} = state, impl) do

    %State{state | busy_workers_impl: impl, busy_workers_state: impl.init()}

  end



  @doc false

  @spec add(State.t(), Poolex.worker()) :: State.t()

  def add(%State{busy_workers_impl: impl, busy_workers_state: busy_workers_state} = state, worker) do

    %State{state | busy_workers_state: impl.add(busy_workers_state, worker)}

  end



  @doc false

  @spec member?(State.t(), Poolex.worker()) :: boolean()

  def member?(%State{busy_workers_impl: impl, busy_workers_state: busy_workers_state}, worker) do

    impl.member?(busy_workers_state, worker)

  end



  @doc false

  @spec remove(State.t(), Poolex.worker()) :: State.t()

  def remove(

        %State{busy_workers_impl: impl, busy_workers_state: busy_workers_state} = state,

        worker

      ) do

    %State{state | busy_workers_state: impl.remove(busy_workers_state, worker)}

  end



  @doc false

  @spec count(State.t()) :: non_neg_integer()

  def count(%State{busy_workers_impl: impl, busy_workers_state: state}) do

    impl.count(state)

  end



  @doc false

  @spec to_list(State.t()) :: list(Poolex.worker())

  def to_list(%State{busy_workers_impl: impl, busy_workers_state: state}) do

    impl.to_list(state)

  end

end