作为gen_server启动,作为pg2模块的封装
pg2这个模块实现了进程组的功能。例如进程组的名称为test,而且有一系列进程位于组内,可能这些进程位于不同的节点上,都可以成为test的成员。不能够直接向test发送消息,但是通过方法get_members/1 和 get_local_members/1获取的组内的进程,然后可以与查出的进程通信。
对外提供几种方法,较为简单:
join(Name) -> PG = {?MODULE, Name}, pg2:create(PG), pg2:join(PG, whereis(?MODULE)). leave(Name) -> PG = {?MODULE, Name}, pg2:leave(PG, whereis(?MODULE)). get_members(Name) -> PG = {?MODULE, Name}, [node(P) || P <- pg2:get_members(PG)]. get_closest_node(Name) -> PG = {?MODULE, Name}, node(pg2:get_closest_pid(PG)).