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

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

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

Future.setExceptionIfUndone介绍

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

代码示例

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

public void exceptionOccurred(Exception exception)
  {
    if(partfuture==ret)
    {
      partfuture    = null;
    }
    ret.setExceptionIfUndone(exception);
  }
});

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

public void exceptionOccurred(Exception exception)
  {
    ready[1]	= true;
    if(ready[0] &&  ready[1])
    {
      ret.setExceptionIfUndone(exception);
    }
  }
}));

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

public void exceptionOccurred(Exception exception)
  {
    ret.setExceptionIfUndone(exception);
  }
});

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

public void exceptionOccurred(Exception exception)
  {
    if(!found)
      ret.setExceptionIfUndone(exception);
  }
});

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

public void exceptionOccurred(Exception exception)
      {
//                if(ComponentTreeNode.this.toString().indexOf("Hunter")!=-1)
//                    System.err.println("searchChildren done2e: "+ComponentTreeNode.this);
        ready[0]	= true;
        if(ready[0] &&  ready[1])
        {
          ret.setExceptionIfUndone(exception);
        }
      }
    }));

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

public void exceptionOccurred(Exception exception)
      {
//				System.out.println("gloaldelehandler endex"+SUtil.arrayToString(args));
        fret.setExceptionIfUndone(exception);
      }
    };

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

public void customResultAvailable(Void result)
  {
    // If all threads done, but no result -> set exception.
    ret.setExceptionIfUndone(new RuntimeException("Cannot retrieve server list."));
  }
});

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

public void customResultAvailable(Void result)
  {
    // If all threads done, but no result -> set exception.
    ret.setExceptionIfUndone(new RuntimeException("No server available."));
  }
});

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

public void exceptionOccurred(Exception exception)
{
  System.out.println("ex: "+exception);
  ret.setExceptionIfUndone(exception);
}

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

public void timeEventOccurred(long currenttime)
  {
    ret.setExceptionIfUndone(new TimeoutException());
  }
});

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

public void customResultAvailable(Void result)
  {
    // If all threads done, but no result -> set exception.
    if(ret.setExceptionIfUndone(new RuntimeException("Cannot retrieve server list.")))
    {
      log(Level.INFO, "Relay cannot retrieve server list.");					
    }
  }
});

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

public void exceptionOccurred(Exception exception)
{
  // Forward timeout exception to future.
  if(exception instanceof TimeoutException)
  {
    fut.setExceptionIfUndone(exception);
    if(fut instanceof ITerminableFuture<?>)
    {
      ((ITerminableFuture)fut).terminate(exception);
    }
  }
}

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

protected void checkFinish()
  {
    if(ongoing==0 && finished && !ret.isDone())
    {
      ret.setExceptionIfUndone(new SecurityException("Unable to retrieve certificate: "+name));
    }
  }
});

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

public void finished()
{
  if(!found)
    ret.setExceptionIfUndone(new SecurityException("TTP not found: "+ttpcid.getName()));
}

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

protected void checkFinish()
  {
    if(ongoing==0 && finished && !ret.isDone())
    {
      ret.setExceptionIfUndone(new SecurityException("Unable to retrieve certificate: "+name));
    }
  }
});

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

public void finished()
{
  if(!found)
    ret.setExceptionIfUndone(new SecurityException("TTP not found: "+ttpcid.getName()));
}

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

public void exceptionOccurred(Exception exception)
      {
        if(!(exception instanceof ComponentTerminatedException))
          agent.getMicroAgent().getLogger().warning("Awareness agent problem, could not get threadpool service: "+exception);
//                exception.printStackTrace();
        ret.setExceptionIfUndone(exception);
      }
    });

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

public void exceptionOccurred(Exception exception)
      {
        if(!(exception instanceof ComponentTerminatedException))
          agent.getMicroAgent().getLogger().warning("Awareness agent problem, could not get threadpool service: "+exception);
//                exception.printStackTrace();
        ret.setExceptionIfUndone(exception);
      }
    });

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

public void customResultAvailable(Void result)
  {
    ret.setExceptionIfUndone(new ServiceNotFoundException(type.getTypeName()));
  }
});

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

public void run()
        {
//                    System.out.println("TIMEOUT: "+System.currentTimeMillis()+" "+filename);

          triggered[0] = true;
          boolean	b = finished.setExceptionIfUndone(new TimeoutException(ComponentTest.this+" did not finish in "+timeout+" ms."));
          if(b && cid[0]!=null)
          {
            cms.destroyComponent(cid[0]);
          }
        }
      }, timeout);

相关文章