如何通过GPAR中的主参与者终止所有从属参与者？

Question

我想让我的主演员在第一个演员完成工作后立即终止所有的奴隶演员<然而，我不知道怎样才能从我的主人那里向所有的奴隶发送广播。这有函数或编程模式吗？

解决这个问题的另一种方法可能是给主人一个所有奴隶的列表，并循环通过它们，给每个奴隶发送一条终止消息，但是奴隶也需要主人作为属性，我认为这是一个问题：

import groovyx.gpars.actor.Actor
import groovyx.gpars.actor.DefaultActor

class Slave extends DefaultActor {
    Actor master
    int t

    void act() {
        t = new Random().nextInt(1337)
        println "It's me, $t"
        master.send 0
    }

}

class Master extends DefaultActor {
    List slaves 

    void afterStart() {
        println "Master initialized!"
    }

    void killTheSlaves() {
        for (i in 0..slaves.size()-1){
            slaves[i].send -1
        }
    }

    void act() {
        react { int num ->
            if (num == 0)
                killTheSlaves()
        }
    }
}

def sl = new Slave().start()

def ma = new Master(slaves: [sl]).start()
sl.master = ma

此代码不编译。
错误消息：

Actor线程Actor线程2 java中发生异常。lang.NullPointerException:无法在组织的null对象上调用方法send（）。科德豪斯。棒极了。运行时。空对象。org上的invokeMethod（NullObject.java:91）。科德豪斯。棒极了。运行时。呼叫站点。PogoMetaClassSite。在org上调用（PogoMetaClassSite.java:48）。科德豪斯。棒极了。运行时。呼叫站点。CallSiteArray。org上的defaultCall（CallSiteArray.java:48）。科德豪斯。棒极了。运行时。呼叫站点。NullCallSite。在org上调用（NullCallSite.java:35）。科德豪斯。棒极了。运行时。呼叫站点。CallSiteArray。org上的defaultCall（CallSiteArray.java:48）。科德豪斯。棒极了。运行时。呼叫站点。抽象调用站点。在org上调用（AbstractCallSite.java:113）。科德豪斯。棒极了。运行时。呼叫站点。抽象调用站点。在从机上调用（AbstractCallSite.java:125）。在groovyx表演（控制台描述14:11）。GPAR。男演员默认演员。groovyx上的handleStart（DefaultActor.java:342）。GPAR。男演员AbstractLoopingActor$1。groovyx上的handleMessage（AbstractLoopingActor.java:70）。GPAR。util。AsyncMessagingCore。在java上运行（AsyncMessagingCore.java:132）。util。同时发生的线程池执行器。java上的runWorker（ThreadPoolExecutor.java:1142）。util。同时发生的线程池执行器$Worker。在java上运行（ThreadPoolExecutor.java:617）。朗。丝线。运行（Thread.java:745）

看来我不能在创造了奴隶后设置sl.master。

有解决办法吗？

非常感谢您的帮助<提前谢谢你！

Answer 1

您应该首先设置参与者，然后启动它们：def sl=new Slave（）def ma=new Master（slaves:[sl]）sl.Master=ma sl.start（）ma。start（）

然而，你的奴隶演员在主人试图杀死他们之前就用完了他们的act（）方法，所以实际上不需要杀死奴隶。

GPars在参与者身上提供了一个终止（）方法来优雅地杀死他们，所以您可以考虑将您的方法更改为：vavillTheSlaves（）{for（i in 0...slaves.size（）-1）{slaves[i]。终止() } }