com.github.rinde.rinsim.event.Event.<init>()方法的使用及代码示例

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

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

Event.<init>介绍

[英]Create a new event without a issuer.
[中]创建没有颁发者的新事件。

代码示例

代码示例来源：origin: com.github.rinde/rinlog

  1. @Override
  2. public void receiveParcel(Auctioneer<T> auctioneer, Parcel p,
  3.   long auctionStartTime) {
  4.  LOGGER.info("{} receiveParcel {}", this, p);
  5.  assignedParcels.add(p);
  6.  eventDispatcher
  7.   .dispatchEvent(new Event(CommunicatorEventType.CHANGE, this));
  8. }

代码示例来源：origin: com.github.rinde/rinlog

  1. /**
  2.  * Notifies this blackboard user of a change in the environment.
  3.  */
  4. public void update() {
  5.  eventDispatcher
  6.   .dispatchEvent(new Event(CommunicatorEventType.CHANGE, this));
  7. }

代码示例来源：origin: com.github.rinde/rinlog

  1. protected void dispatchChangeEvent() {
  2.  eventDispatcher.dispatchEvent(
  3.   new Event(RoutePlannerEventType.CHANGE, this));
  4. }

代码示例来源：origin: rinde/RinSim

  1. void close() {
  2.  if (!shell.isDisposed()) {
  3.   display.asyncExec(new Runnable() {
  4.    @Override
  5.    public void run() {
  6.     shell.close();
  7.    }
  8.   });
  9.  }
  10.  if (builder.callback().isPresent()) {
  11.   builder.callback().get()
  12.    .handleEvent(new Event(Clock.ClockEventType.STOPPED, null));
  13.  }
  14. }

代码示例来源：origin: rinde/RinSim

  1. /**
  2.  * Start the simulation.
  3.  */
  4. @Override
  5. public final void start() {
  6.  checkState(!isTicking(), "Time is already ticking.");
  7.  isTicking = true;
  8.  eventDispatcher.dispatchEvent(new Event(ClockEventType.STARTED, this));
  9.  doStart();
  10.  eventDispatcher.dispatchEvent(new Event(ClockEventType.STOPPED, this));
  11. }

代码示例来源：origin: com.github.rinde/rinlog

  1. @Override
  2. public boolean releaseParcel(Parcel p) {
  3.  checkArgument(!pdpModel.get().getParcelState(p).isPickedUp()
  4.   && !pdpModel.get().getParcelState(p).isTransitionState());
  5.  LOGGER.info("{} releaseParcel {}", this, p);
  6.  checkArgument(assignedParcels.contains(p));
  7.  assignedParcels.remove(p);
  8.  checkState(!assignedParcels.contains(p));
  9.  eventDispatcher
  10.   .dispatchEvent(new Event(CommunicatorEventType.CHANGE, this));
  11.  return true;
  12. }

代码示例来源：origin: rinde/RinSim

  1. @Override
  2.  public void handleEvent(Event e) {
  3.   @SuppressWarnings("unchecked")
  4.   final StateTransitionEvent<Trigger, RealtimeModel> event =
  5.    (StateTransitionEvent<Trigger, RealtimeModel>) e;
  6.   LOGGER.debug("{} {}", timeLapse, event);
  7.   if ((event.newState == realtimeState || event.newState == INIT_RT)
  8.    && eventDispatcher.hasListenerFor(SWITCH_TO_REAL_TIME)) {
  9.    eventDispatcher.dispatchEvent(new Event(SWITCH_TO_REAL_TIME, ref));
  10.   } else if ((event.newState == st || event.newState == INIT_ST)
  11.    && eventDispatcher.hasListenerFor(SWITCH_TO_SIM_TIME)) {
  12.    eventDispatcher.dispatchEvent(new Event(SWITCH_TO_SIM_TIME, ref));
  13.   }
  14.  }
  15. }, StateMachineEvent.values());

代码示例来源：origin: rinde/RinSim

  1. @OverridingMethodsMustInvokeSuper
  2. void cleanUpAfterException() {
  3.  eventDispatcher.dispatchEvent(new Event(ClockEventType.STOPPED, this));
  4. }

代码示例来源：origin: rinde/RinSim

  1. @Override
  2. public void doneForNow() {
  3.  try {
  4.   checkState(solveCount.decrementAndGet() >= 0);
  5.   if (solveCount.get() == 0) {
  6.    LOGGER.trace("doneForNow");
  7.    eventDispatcher.safeDispatchEvent(
  8.     new Event(EventType.DONE_COMPUTING, reference));
  9.    simSolverEventDispatcher.safeDispatchEvent(
  10.     new SolverEvent(RtSimSolver.EventType.DONE,
  11.      currentSchedule, currentState));
  12.   }
  13.  } catch (final RuntimeException e) {
  14.   reportException(e);
  15.  }
  16. }

代码示例来源：origin: rinde/RinSim

  1. void handleFailure(Throwable t) {
  2.  if (t instanceof CancellationException
  3.   || t instanceof InterruptedException) {
  4.   LOGGER.info("RealtimeSolver execution got cancelled/interrupted");
  5.   try {
  6.    eventDispatcher.dispatchEvent(
  7.     new Event(RtSimSolverSchedulerBridge.EventType.DONE_COMPUTING,
  8.      reference));
  9.   } catch (final RuntimeException e) {
  10.    simSolversManager.addException(e);
  11.   }
  12.  } else {
  13.   simSolversManager.addException(t);
  14.  }
  15. }

代码示例来源：origin: rinde/RinSim

  1. eventDispatcher.dispatchEvent(new Event(
  2.  RtSimSolverSchedulerBridge.EventType.START_COMPUTING, reference));

代码示例来源：origin: rinde/RinSim

  1. private void dispatchEvents(TimeLapse timeLapse) {
  2.  TimedEvent e = null;
  3.  while ((e = scenarioQueue.peek()) != null
  4.   && e.getTime() <= timeLapse.getTime()) {
  5.   scenarioQueue.poll();
  6.   if (status == null) {
  7.    LOGGER.info("scenario started at virtual time:" + timeLapse.getTime());
  8.    status = EventType.SCENARIO_STARTED;
  9.    disp.dispatchEvent(new Event(status, this));
  10.   }
  11.   dispatch(e);
  12.  }
  13.  if ((e = scenarioQueue.peek()) != null
  14.   && e.getTime() <= timeLapse.getTime() + timeLapse.getTickLength()
  15.   && clock instanceof RealtimeClockController) {
  16.   LOGGER.trace("Found an event in next tick, switch to RT");
  17.   ((RealtimeClockController) clock).switchToRealTime();
  18.  }
  19.  if (e == null && status != EventType.SCENARIO_FINISHED) {
  20.   status = EventType.SCENARIO_FINISHED;
  21.   disp.dispatchEvent(new Event(status, this));
  22.  }
  23. }

代码示例来源：origin: rinde/RinSim

  1. @Override
  2. public void show() {
  3.  shell.open();
  4.  for (final Listener l : listeners) {
  5.   l.handleEvent(new Event(EventType.SHOW, this));
  6.  }
  7.  if (!builder.viewOptions().contains(ViewOption.ASYNC)) {
  8.   while (!shell.isDisposed()) {
  9.    if (!display.readAndDispatch()) {
  10.     display.sleep();
  11.    }
  12.   }
  13.   if (shell.isDisposed()) {
  14.    clockController.stop();
  15.   }
  16.  }
  17. }

代码示例来源：origin: com.github.rinde/rinsim-scenario

  1. private void dispatchEvents(TimeLapse timeLapse) {
  2.  TimedEvent e = null;
  3.  while ((e = scenarioQueue.peek()) != null
  4.   && e.getTime() <= timeLapse.getTime()) {
  5.   scenarioQueue.poll();
  6.   if (status == null) {
  7.    LOGGER.info("scenario started at virtual time:" + timeLapse.getTime());
  8.    status = EventType.SCENARIO_STARTED;
  9.    disp.dispatchEvent(new Event(status, this));
  10.   }
  11.   dispatch(e);
  12.  }
  13.  if ((e = scenarioQueue.peek()) != null
  14.   && e.getTime() <= timeLapse.getTime() + timeLapse.getTickLength()
  15.   && clock instanceof RealtimeClockController) {
  16.   LOGGER.trace("Found an event in next tick, switch to RT");
  17.   ((RealtimeClockController) clock).switchToRealTime();
  18.  }
  19.  if (e == null && status != EventType.SCENARIO_FINISHED) {
  20.   status = EventType.SCENARIO_FINISHED;
  21.   disp.dispatchEvent(new Event(status, this));
  22.  }
  23. }

代码示例来源：origin: rinde/RinSim

  1. @Test(expected = IllegalArgumentException.class)
  2. public void dispatchEventFail2() {
  3.  dispatcher.dispatchEvent(new Event(OTHER_EVENT1));
  4. }

代码示例来源：origin: com.github.rinde/rinlog

  1. routePlannerChanged = new AtomicBoolean();
  2. eventDispatcher = new EventDispatcher(TruckEvent.values());
  3. routeChangedEvent = new Event(TruckEvent.ROUTE_CHANGE, this);
  4. LOGGER.trace("Truck constructor, {}, {}, {}, {}.", rp, c, ra,
  5.  lazyRouteComp);

代码示例来源：origin: com.github.rinde/rinsim-pdptw

  1. clock.getCurrentTime());
  2. if (totalVehicles == lastArrivalTimeAtDepot.size()) {
  3.  eventDispatcher.dispatchEvent(new Event(
  4.   StatsProvider.EventTypes.ALL_VEHICLES_AT_DEPOT, this));

代码示例来源：origin: rinde/RinSim

  1. clock.getCurrentTime());
  2. if (totalVehicles == lastArrivalTimeAtDepot.size()) {
  3.  eventDispatcher.dispatchEvent(new Event(
  4.   StatsProvider.EventTypes.ALL_VEHICLES_AT_DEPOT, this));

代码示例来源：origin: rinde/RinSim

  1. assertFalse(dispatcher.hasListenerFor(OTHER_EVENT1));
  2. dispatcher.dispatchEvent(new Event(EVENT2));
  3. assertEquals(asList(), l1.getEventTypeHistory());
  4. assertEquals(asList(EVENT2), l2.getEventTypeHistory());
  5. assertEquals(asList(EVENT2), l3.getEventTypeHistory());
  6. dispatcher.dispatchEvent(new Event(EVENT3));
  7. assertEquals(asList(), l1.getEventTypeHistory());
  8. assertEquals(asList(EVENT2), l2.getEventTypeHistory());
  9. assertEquals(asList(EVENT2, EVENT3), l3.getEventTypeHistory());
  10. dispatcher.dispatchEvent(new Event(EVENT1));
  11. assertEquals(asList(EVENT1), l1.getEventTypeHistory());
  12. assertEquals(asList(EVENT2, EVENT1), l2.getEventTypeHistory());
  13. assertEquals(asList(EVENT2, EVENT3, EVENT1), l3.getEventTypeHistory());
  14. dispatcher.dispatchEvent(new Event(EVENT3));
  15. assertEquals(asList(EVENT1), l1.getEventTypeHistory());
  16. assertEquals(asList(EVENT2, EVENT1), l2.getEventTypeHistory());

内容来源于网络，如有侵权，请联系作者删除！

Event

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com