Packages

workex

0.0.2
0.10.0 0.9.0 0.8.0 0.7.0 0.6.0 0.5.0 0.4.0 0.3.0 0.2.0 0.1.0 0.0.3 0.0.2 0.0.1

A behaviour for simple flow control and backpressure.

HexDocs

Current section

Files

Jump to
Readme
13 Versions
1 Dependency
Dependants
Files
Activity
workex lib throttler.ex
Raw

lib/throttler.ex 

defmodule Workex.Throttler do

  def exec_and_measure(fun) do

    {time, result} = :timer.tc(fun)

    {round(time / 1000) + 1, result}

  end



  def throttle(time, fun) do

    {exec_time, result} = exec_and_measure(fun)

    do_throttle(time, exec_time)

    result

  end



  defp do_throttle(time, exec_time) when exec_time < time do

    :timer.sleep(time - exec_time)

  end



  defp do_throttle(_, _), do: :ok

end