ipojo 重新配置期间的数据传输

Question

我在重新配置期间遇到了与ipojo 组件之间的数据传输相关的问题。 这是一个例子：

• 组件Calcul_1 提供计算服务以返回值(a+b)（例如：f(a,b)=> (a+b)）
• 组件Calcul_2 提供计算服务以返回值(a*b)（例如：f(a,b)=> (a*b)）

这两个组件实现了相同的计算服务（例如：f）。

• 现在，我有一个组件CallCalcul 使用Calcul_1 的计算服务。组件CallCalcul 调用组件Calcul_1 中的f(5,6)。然后，CallCalcul component 收到 11 的值。

问题：

1. 当Calcul_1 从CallCalcul 接收到值(5,6)（尚未计算）时，CallCalcul 通过将连接器更改为Calcul_2 重新配置，即它绑定到Calcul_2。在这种情况下，如何将(5,6)从Calcul_1传输到Calcul_2并将(5*6=30)返回到CallCalcul？

2. 当Calcul_1 接收到来自CallCalcul 的值(5,6)（并计算它们，即5+6=11）时，CallCalcul 重新配置。在这种情况下，如何将11 传输到Calcul_2 并将这个值返回给CallCalcul？

Answer 1

据我所知，ipojo 会处理同步，因此不会发生这种行为。

来自ipojo documentation：

同步由 iPOJO 管理。一旦你“接触”一个方法中的一个依赖项，iPOJO 确保你将保留这些对象直到方法结束。嵌套方法将共享相同的服务对象集。

所以只要你在同一个方法（或嵌套方法）中，你就知道你的服务自从你第一次访问它之后就没有被修改过（我假设你对f的调用是同步的，所以如果我错了，请告诉我）。在方法调用过程中，Calcul_1 组件不会被 Calcul_2 替换。

不过，我想这也意味着如果你想让重新配置生效，你必须使用你的服务到达方法的末尾。例如，如果您的组件启动一个具有如下函数的线程：

public void run() {
    while(!end) {
        //while this function is running, myService will not change
        int var = myService.f(a,b); 
        // ... do something with the result
        Thread.sleep(SLEEP_TIME);
    }
}

如果此函数继续运行，即使您的过滤器被修改，ipojo 也不会将新服务绑定到myService。您应该将对该服务的调用放在另一个辅助方法中。它将允许 ipojo 在重新配置您的组件时锁定对服务的访问。例如：

public void run() {
    while(!end) {
        // the service may not be the same each time because this function does
        // not directly use the service
        int var = callDynamicService(a,b); 
        // ... do something with the result
        Thread.sleep(SLEEP_TIME);
    }
}

private int callDynamicService(int a, int b) {
    return myService.f(a,b);
}