jadex.commons.future.Future.setResult()方法的使用及代码示例

x33g5p2x  于2022-01-19 转载在 其他  
字(4.7k)|赞(0)|评价(0)|浏览(163)

本文整理了Java中jadex.commons.future.Future.setResult()方法的一些代码示例,展示了Future.setResult()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Future.setResult()方法的具体详情如下:
包路径:jadex.commons.future.Future
类名称:Future
方法名:setResult

Future.setResult介绍

[英]Set the result. Listener notifications occur on calling thread of this method.
[中]设定结果。侦听器通知发生在此方法的调用线程上。

代码示例

代码示例来源:origin: net.sourceforge.jadex/jadex-bridge

public void intermediateResultAvailable(IService result)
        {
//                    if(type.getName().indexOf("IRepositoryAccess")!=-1)
//                        System.out.println("ir: "+result);
          ret.setResult(result);
        }

代码示例来源:origin: org.activecomponents.jadex/jadex-bridge

public void exceptionOccurred(Exception exception)
        {
//					System.out.println("kaputtt: "+exception);
//					super.exceptionOccurred(exception);
          ret.setResult(null);
        }
      });

代码示例来源:origin: net.sourceforge.jadex/jadex-platform-base

public void customResultAvailable(Object result)
  {
    ret.setResult((T)result);
  }
});

代码示例来源:origin: net.sourceforge.jadex/jadex-platform-base

public void customResultAvailable(Object result)
  {
    ret.setResult(null);
  }
});

代码示例来源:origin: net.sourceforge.jadex/jadex-platform-base

public void exceptionOccurred(Exception exception)
  {
    // No settings service: ignore.
    ret.setResult(null);
  }
});

代码示例来源:origin: net.sourceforge.jadex/jadex-platform-base

public void finished()
{
  ret.setResult(null);
}
public void exceptionOccurred(Exception exception)

代码示例来源:origin: net.sourceforge.jadex/jadex-platform-base

public void exceptionOccurred(Exception exception)
  {
    // No settings service: ignore.
    SecurityService.this.platformpasses	= null;
    ret.setResult(null);
  }
});

代码示例来源:origin: org.activecomponents.jadex/jadex-platform

public void finished()
{
  done.setResult(null);
}
public void exceptionOccurred(Exception exception)

代码示例来源:origin: org.activecomponents.jadex/jadex-bridge

public void resultAvailable(Void result)
{
  Collections.sort(unrankedservices, new Comparator<S>()
  {
    public int compare(S s1, S s2)
    {
      return (int)-Math.signum(evalmap.get(s1) - evalmap.get(s2));
    }
  });
  ret.setResult(unrankedservices);
}

代码示例来源:origin: net.sourceforge.jadex/jadex-platform-base

public void exceptionOccurred(Exception exception)
        {
//                    open.remove(fut);
          fut.setResult((CMSComponentDescription[])ret.toArray(new CMSComponentDescription[ret.size()]));
        }
      });

代码示例来源:origin: org.activecomponents.jadex/jadex-platform

public void exceptionOccurred(Exception exception)
        {
//                    open.remove(fut);
          fut.setResult((CMSComponentDescription[])ret.toArray(new CMSComponentDescription[ret.size()]));
        }
      }));

代码示例来源:origin: org.activecomponents.jadex/jadex-commons

public void resultAvailable(E result)
{
  synchronized(resultIndicator) {
    if (!resultIndicator.isDone()) {
      resultIndicator.setResult(null);
      action.accept(result);
      ret.setResult(null);
    }
  }
}

代码示例来源:origin: net.sourceforge.jadex/jadex-bridge

public void resultAvailable(Object result)
          {
//                        System.out.println("ser resultb: "+agent.isComponentThread());
            
            addResult(result);
            call.setResult(null);
//                        opencalls.remove(this);
          }
          public void exceptionOccurred(Exception exception)

代码示例来源:origin: net.sourceforge.jadex/jadex-bridge

public void customResultAvailable(T result)
  {
    ret.setResult(calculateEvaluation(result));
  }
};

代码示例来源:origin: net.sourceforge.jadex/jadex-kernel-base

public void run() 
  {
    ret.setResult(interpreter.getArguments());
  }
});

代码示例来源:origin: net.sourceforge.jadex/jadex-platform-base

public IFuture<Void> execute(IInternalAccess ia)
      {
        SendInfo si = unacked.remove(id);
        if(si!=null)
        {
//                    System.out.println("received ack: "+si.getId()+" "+si.getTryCnt());
          si.getTimer().cancel();
          si.getResult().setResult(content);
        }
        return IFuture.DONE;
      }
    });

代码示例来源:origin: net.sourceforge.jadex/jadex-platform-base

public void customResultAvailable(List<IResourceIdentifier> result)
  {
    final List<URL> res = new ArrayList<URL>();
    for(int i=0; i<result.size(); i++)
    {
      res.add(result.get(i).getLocalIdentifier().getUrl());
    }
    
    res.addAll(getInternalNonManagedURLs());
    ret.setResult(res);
  }
});

代码示例来源:origin: net.sourceforge.jadex/jadex-platform-base

public void resultAvailable(Void result)
{
  if(++i[0]<receivers.length)
  {
    deliverToReceiver(receivers, i[0], cms, classloader, decoded, msg, logger, messagetype).addResultListener(this);
  }
  else
  {
    ret.setResult(null);
  }
}

代码示例来源:origin: net.sourceforge.jadex/jadex-platform-base

public void customResultAvailable(IExternalAccess ea)
        {
//                    System.err.println("Model class loader: "+ea.getModel().getName()+", "+ea.getModel().getClassLoader());
//                        classloadercache.put(ci.getParent(), ea.getModel().getClassLoader());
          ret.setResult(ea.getModel().getResourceIdentifier());
        }
      });

代码示例来源:origin: net.sourceforge.jadex/jadex-bridge

public void customResultAvailable(Boolean supported)
  {
    if(supported.booleanValue())
    {
      ret.setResult(ps);
    }
    else
    {
      getPublishService(instance, type, services).addResultListener(new DelegationResultListener<IPublishService>(ret));
    }
  }
}));

相关文章