Erlang并发编程：使用消息传递实现简单的并发任务调度器

这个示例展示了如何使用Erlang的并发特性和消息传递机制来构建一个简单的任务调度器。它利用Erlang的进程管理和消息队列，将任务分配给不同的进程并执行，展示了Erlang在并发编程中的强大表现。

-module(task_scheduler).
-export([start/0, new_task/1, worker/0, handle_task/1]).

start() ->
    spawn(task_scheduler, worker, []).

new_task(Task) ->
    TaskScheduler = self(),
    spawn(fun() -> TaskScheduler ! {new_task, Task} end).

worker() ->
    receive
        {new_task, Task} ->
            spawn(task_scheduler, handle_task, [Task]),
            worker()
    end.

handle_task(Task) ->
    %% 这里模拟任务的执行，实际中可以是任何任务处理逻辑
    io:format("执行任务: ~p~n", [Task]).

% 启动任务调度器
task_scheduler:start(),
% 创建新任务
task_scheduler:new_task("任务1"),
task_scheduler:new_task("任务2").

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