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

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

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

Event.getEventType介绍

暂无

代码示例

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

  1. public void safeDispatchEvent(Event e) {
  2.  dispatching.incrementAndGet();
  3.  final Set<Listener> targetListeners;
  4.  synchronized (listeners) {
  5.   checkCanDispatchEventType(e.getEventType());
  6.   targetListeners = ImmutableSet.copyOf(listeners.get(e.getEventType()));
  7.  }
  8.  for (final Listener l : targetListeners) {
  9.   l.handleEvent(e);
  10.  }
  11.  dispatching.decrementAndGet();
  12.  update();
  13. }

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

  1. public void safeDispatchEvent(Event e) {
  2.  dispatching.incrementAndGet();
  3.  final Set<Listener> targetListeners;
  4.  synchronized (listeners) {
  5.   checkCanDispatchEventType(e.getEventType());
  6.   targetListeners = ImmutableSet.copyOf(listeners.get(e.getEventType()));
  7.  }
  8.  for (final Listener l : targetListeners) {
  9.   l.handleEvent(e);
  10.  }
  11.  dispatching.decrementAndGet();
  12.  update();
  13. }

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

  1. /**
  2.  * Dispatch an event. Notifies all listeners that are listening for this type
  3.  * of event.
  4.  * @param e The event to be dispatched, only events with a supported type can
  5.  *          be dispatched.
  6.  */
  7. public void dispatchEvent(Event e) {
  8.  synchronized (listeners) {
  9.   dispatching.incrementAndGet();
  10.   checkCanDispatchEventType(e.getEventType());
  11.   for (final Listener l : listeners.get(e.getEventType())) {
  12.    l.handleEvent(e);
  13.   }
  14.   dispatching.decrementAndGet();
  15.  }
  16.  update();
  17. }

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

  1. /**
  2.  * Dispatch an event. Notifies all listeners that are listening for this type
  3.  * of event.
  4.  * @param e The event to be dispatched, only events with a supported type can
  5.  *          be dispatched.
  6.  */
  7. public void dispatchEvent(Event e) {
  8.  synchronized (listeners) {
  9.   dispatching.incrementAndGet();
  10.   checkCanDispatchEventType(e.getEventType());
  11.   for (final Listener l : listeners.get(e.getEventType())) {
  12.    l.handleEvent(e);
  13.   }
  14.   dispatching.decrementAndGet();
  15.  }
  16.  update();
  17. }

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

  1. void doHandleEvent(Event e) {
  2.  synchronized (computingSimSolvers) {
  3.   final boolean isComputingBefore = isComputing();
  4.   LOGGER.trace("receive: {}, computing: {}, clock is ticking: {}, {}", e,
  5.    isComputingBefore, clock.isTicking(), computingSimSolvers);
  6.   if (e.getEventType() == EventType.START_COMPUTING) {
  7.    if (!isComputingBefore) {
  8.     LOGGER.debug("start computing -> switch to real time");
  9.     clock.switchToRealTime();
  10.    }
  11.    computingSimSolvers.add((RtSimSolverSchedulerBridge) e.getIssuer());
  12.   } else if (e.getEventType() == EventType.DONE_COMPUTING) {
  13.    // done computing
  14.    checkState(computingSimSolvers.remove(e.getIssuer()));
  15.    // if (!isComputing()) {
  16.    // stop();
  17.    // }
  18.   } else {
  19.    throw new IllegalArgumentException("Unexpected event: " + e);
  20.   }
  21.  }
  22. }

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

  1. @Override
  2.  public void handleEvent(Event e) {
  3.   if (e
  4.    .getEventType() == ScenarioController.EventType.SCENARIO_FINISHED) {
  5.    sim.stop();
  6.   }
  7.  }
  8. });

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

  1. @Override
  2. public void handleEvent(Event e) {
  3.  verify(e instanceof PDPModelEvent);
  4.  final PDPModelEvent event = (PDPModelEvent) e;
  5.  final Box box = (Box) verifyNotNull(event.parcel);
  6.  if (e.getEventType() == PDPModelEventType.END_PICKUP) {
  7.   occupiedPositions.remove(box.getPickupLocation());
  8.  }
  9.  if (e.getEventType() == PDPModelEventType.END_DELIVERY) {
  10.   final long duration = DoubleMath.roundToLong(
  11.    FactoryExample.SERVICE_DURATION / 2d
  12.     + rng.nextDouble() * FactoryExample.SERVICE_DURATION,
  13.    RoundingMode.CEILING);
  14.   simulator.get().unregister(box);
  15.   final BoxHandle bh = box.boxHandle;
  16.   bh.wordIndex = (bh.wordIndex + 1) % points.size();
  17.   final Point dest;
  18.   if (bh.index >= points.get(bh.wordIndex).size()) {
  19.    dest = rndBorder();
  20.   } else {
  21.    dest = points.get(bh.wordIndex).get(bh.index);
  22.    occupiedPositions.add(dest);
  23.   }
  24.   final Box newBox = new Box(box.getDeliveryLocation(),
  25.    dest, duration, bh);
  26.   bh.box = newBox;
  27.   simulator.get().register(newBox);
  28.  }
  29. }

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

  1. @Override
  2. public void handleEvent(Event e) {
  3.  verify(e instanceof PDPModelEvent);
  4.  final PDPModelEvent event = (PDPModelEvent) e;
  5.  final Box box = (Box) verifyNotNull(event.parcel);
  6.  if (e.getEventType() == PDPModelEventType.END_PICKUP) {
  7.   occupiedPositions.remove(box.getPickupLocation());
  8.  }
  9.  if (e.getEventType() == PDPModelEventType.END_DELIVERY) {
  10.   final long duration = DoubleMath.roundToLong(
  11.    FactoryExample.SERVICE_DURATION / 2d
  12.     + rng.nextDouble() * FactoryExample.SERVICE_DURATION,
  13.    RoundingMode.CEILING);
  14.   simulator.get().unregister(box);
  15.   final BoxHandle bh = box.boxHandle;
  16.   bh.wordIndex = (bh.wordIndex + 1) % points.size();
  17.   final Point dest;
  18.   if (bh.index >= points.get(bh.wordIndex).size()) {
  19.    dest = rndBorder();
  20.   } else {
  21.    dest = points.get(bh.wordIndex).get(bh.index);
  22.    occupiedPositions.add(dest);
  23.   }
  24.   final Box newBox = new Box(box.getDeliveryLocation(),
  25.    dest, duration, bh);
  26.   bh.box = newBox;
  27.   simulator.get().register(newBox);
  28.  }
  29. }

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

  1. @Override
  2.  public void handleEvent(Event e) {
  3.   log.add(LogEntry.create(clock.getCurrentTime(),
  4.    clock.getCurrentTime() + clock.getTickLength(),
  5.    clock.getClockMode(), e.getEventType()));
  6.  }
  7. }, SWITCH_TO_REAL_TIME, SWITCH_TO_SIM_TIME, STARTED, STOPPED);

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

  1. @Override
  2.  public void handleEvent(Event e) {
  3.   if (e.getEventType() == PDPModelEventType.NEW_PARCEL) {
  4.    verify(e instanceof PDPModelEvent);
  5.    final PDPModelEvent event = (PDPModelEvent) e;
  6.    timeline.addParcel(new ParcelInfo(event.time,
  7.     verifyNotNull(event.parcel)));
  8.   }
  9.  }
  10. }, PDPModelEventType.NEW_PARCEL);

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

  1. @Override
  2.  public void handleEvent(Event e) {
  3.   if (e.getEventType() == PDPModelEventType.NEW_PARCEL) {
  4.    verify(e instanceof PDPModelEvent);
  5.    final PDPModelEvent event = (PDPModelEvent) e;
  6.    timeline.addParcel(new ParcelInfo(event.time,
  7.     verifyNotNull(event.parcel)));
  8.   }
  9.  }
  10. }, PDPModelEventType.NEW_PARCEL);

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

  1. @Override
  2.  public void handleEvent(Event e) {
  3.   log.add(logEntry(clock.getCurrentTime(), e.getEventType()));
  4.  }
  5. }, RtClockEventType.values());

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

  1. @Override
  2.  public void handleEvent(Event e) {
  3.   verify(e instanceof CommModelEvent);
  4.   final CommModelEvent event = (CommModelEvent) e;
  5.   if (e.getEventType() == CommModel.EventTypes.ADD_COMM_USER) {
  6.    addUIObject(event.getUser(), event.getDevice());
  7.   } else {
  8.    removeUIObject(event.getUser());
  9.   }
  10.  }
  11. }, CommModel.EventTypes.ADD_COMM_USER,

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

  1. @Override
  2. public void handleEvent(Event e) {
  3.  if (e.getEventType() == ClockEventType.STARTED) {
  4.   startTimeReal = System.currentTimeMillis();
  5.   startTimeSim = clock.getCurrentTime();
  6.   computationTime = 0;
  7.  } else if (e.getEventType() == ClockEventType.STOPPED) {
  8.   computationTime = System.currentTimeMillis() - startTimeReal;
  9.   simulationTime = clock.getCurrentTime() - startTimeSim;
  10.  } else if (e.getEventType() == RoadEventType.MOVE) {
  11.   verify(e instanceof MoveEvent);
  12.   final MoveEvent me = (MoveEvent) e;
  13.  } else if (e.getEventType() == PDPModelEventType.START_PICKUP) {
  14.   verify(e instanceof PDPModelEvent);
  15.   final PDPModelEvent pme = (PDPModelEvent) e;
  16.  } else if (e.getEventType() == PDPModelEventType.END_PICKUP) {
  17.   totalPickups++;
  18.  } else if (e.getEventType() == PDPModelEventType.START_DELIVERY) {
  19.   final PDPModelEvent pme = (PDPModelEvent) e;
  20.  } else if (e.getEventType() == PDPModelEventType.END_DELIVERY) {
  21.   totalDeliveries++;
  22.  } else if (e.getEventType() == SCENARIO_EVENT) {
  23.   final ScenarioEvent se = (ScenarioEvent) e;
  24.   if (se.getTimedEvent() instanceof AddParcelEvent) {
  25.  } else if (e.getEventType() == NEW_PARCEL) {

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

  1. @Override
  2. public void handleEvent(Event e) {
  3.  if (e.getEventType() == ClockEventType.STARTED) {
  4.   startTimeReal = System.currentTimeMillis();
  5.   startTimeSim = clock.getCurrentTime();
  6.   computationTime = 0;
  7.  } else if (e.getEventType() == ClockEventType.STOPPED) {
  8.   computationTime = System.currentTimeMillis() - startTimeReal;
  9.   simulationTime = clock.getCurrentTime() - startTimeSim;
  10.  } else if (e.getEventType() == RoadEventType.MOVE) {
  11.   verify(e instanceof MoveEvent);
  12.   final MoveEvent me = (MoveEvent) e;
  13.  } else if (e.getEventType() == PDPModelEventType.START_PICKUP) {
  14.   verify(e instanceof PDPModelEvent);
  15.   final PDPModelEvent pme = (PDPModelEvent) e;
  16.  } else if (e.getEventType() == PDPModelEventType.END_PICKUP) {
  17.   totalPickups++;
  18.  } else if (e.getEventType() == PDPModelEventType.START_DELIVERY) {
  19.   final PDPModelEvent pme = (PDPModelEvent) e;
  20.  } else if (e.getEventType() == PDPModelEventType.END_DELIVERY) {
  21.   totalDeliveries++;
  22.  } else if (e.getEventType() == SCENARIO_EVENT) {
  23.   final ScenarioEvent se = (ScenarioEvent) e;
  24.   if (se.getTimedEvent() instanceof AddParcelEvent) {
  25.  } else if (e.getEventType() == NEW_PARCEL) {

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

  1. if (e.getEventType() == CommunicatorEventType.CHANGE) {
  2.  changed = true;
  3.  if (!lazyRouteComputing) {

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

  1. @Test
  2. public void followPathEventIssuerType() {
  3.  final MovingRoadUser user = new TestRoadUser();
  4.  model.addObjectAt(user, SW);
  5.  final ListenerEventHistory list = new ListenerEventHistory();
  6.  model.getEventAPI().addListener(list, RoadEventType.MOVE);
  7.  assertTrue(list.getHistory().isEmpty());
  8.  model.followPath(user, newLinkedList(asList(SW, SE, NE, NW)),
  9.   TimeLapseFactory.create(0, 10));
  10.  assertEquals(1, list.getHistory().size());
  11.  assertEquals(RoadEventType.MOVE, list.getHistory().get(0).getEventType());
  12.  assertEquals(model, list.getHistory().get(0).getIssuer());
  13. }

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

  1. @Test
  2. public void moveToEventIssuerType() {
  3.  final MovingRoadUser user = new TestRoadUser();
  4.  model.addObjectAt(user, SW);
  5.  final ListenerEventHistory list = new ListenerEventHistory();
  6.  model.getEventAPI().addListener(list, RoadEventType.MOVE);
  7.  assertTrue(list.getHistory().isEmpty());
  8.  model.moveTo(user, NW, TimeLapseFactory.create(0, 10));
  9.  assertEquals(1, list.getHistory().size());
  10.  assertEquals(RoadEventType.MOVE, list.getHistory().get(0).getEventType());
  11.  assertEquals(model, list.getHistory().get(0).getIssuer());
  12. }

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

  1. assertThat(events.get(0).getEventType()).isEqualTo(EventType.NEW_SCHEDULE);
  2. assertThat(events.get(1).getEventType()).isEqualTo(EventType.DONE);

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

  1. @Override
  2.  public void handleEvent(Event e) {
  3.   GraphEvent ge = (GraphEvent) e;
  4.   if (e.getEventType() == ADD_CONNECTION) {
  5.    assertTrue(ge.getGraph().hasConnection(ge.getConnection()));
  6.    assertEquals(
  7.     ge.getConnection(),
  8.     ge.getGraph().getConnection(ge.getConnection().from(),
  9.      ge.getConnection().to()));
  10.   } else if (e.getEventType() == REMOVE_CONNECTION) {
  11.    assertFalse(ge.getGraph().hasConnection(ge.getConnection().from(),
  12.     ge.getConnection().to()));
  13.   } else if (e.getEventType() == CHANGE_CONNECTION_DATA) {
  14.    assertTrue(ge.getGraph().hasConnection(ge.getConnection().from(),
  15.     ge.getConnection().to()));
  16.    assertEquals(
  17.     ge.getConnection().data(),
  18.     ge.getGraph()
  19.      .getConnection(ge.getConnection().from(),
  20.       ge.getConnection().to())
  21.      .data());
  22.   }
  23.  }
  24. }

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

Event

相关文章

    查看更多

    热门标签

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

    最新文章

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