使用Elixir编写基于OTP的并发应用示例

这个示例演示了如何使用Elixir语言构建基于OTP（开放电信平台）的并发应用。其中，使用了OTP的Supervisor来管理进程，并通过消息传递进行通信和协作。示例中创建了一个简单的工作者进程池，用于处理任务。通过这种方式，展示了Elixir和OTP如何简化并发编程。

defmodule Worker do
  def start_link do
    Task.start_link(fn -> work() end)
  end

  defp work do
    receive do
      {:perform_task, task} ->
        IO.puts("处理任务：#{task}")
        # 在实际应用中执行任务的逻辑
        work()
    end
  end
end

defmodule WorkerPool do
  use Supervisor

  def start_link do
    Supervisor.start_link(__MODULE__, [])
  end

  def init([]) do
    children = [
      worker(Worker, [], id: :worker1),
      worker(Worker, [], id: :worker2),
      worker(Worker, [], id: :worker3)
    ]
    supervise(children, strategy: :simple_one_for_one)
  end

  def perform_task(task) do
    {:ok, pid} = Supervisor.start_child(__MODULE__, [])
    GenServer.call(pid, {:perform_task, task})
  end
end

# 使用示例
{:ok, pool} = WorkerPool.start_link()
WorkerPool.perform_task("任务1")
WorkerPool.perform_task("任务2")
WorkerPool.perform_task("任务3")

免责申明：文章和图片全部来源于公开网络，如有侵权，请通知删除 server@dude6.com