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

AsyncDispatcher.dispatch介绍

[英]The thread name for dispatcher.
[中]调度程序的线程名称。

代码示例

代码示例来源：origin: com.github.jiayuhan-it/hadoop-yarn-common

@Override
 public void run() {
  while (!stopped && !Thread.currentThread().isInterrupted()) {
   drained = eventQueue.isEmpty();
   // blockNewEvents is only set when dispatcher is draining to stop,
   // adding this check is to avoid the overhead of acquiring the lock
   // and calling notify every time in the normal run of the loop.
   if (blockNewEvents) {
    synchronized (waitForDrained) {
     if (drained) {
      waitForDrained.notify();
     }
    }
   }
   Event event;
   try {
    event = eventQueue.take();
   } catch(InterruptedException ie) {
    if (!stopped) {
     LOG.warn("AsyncDispatcher thread interrupted", ie);
    }
    return;
   }
   if (event != null) {
    dispatch(event);
   }
  }
 }
};

代码示例来源：origin: ch.cern.hadoop/hadoop-yarn-common

@Override
 public void run() {
  while (!stopped && !Thread.currentThread().isInterrupted()) {
   drained = eventQueue.isEmpty();
   // blockNewEvents is only set when dispatcher is draining to stop,
   // adding this check is to avoid the overhead of acquiring the lock
   // and calling notify every time in the normal run of the loop.
   if (blockNewEvents) {
    synchronized (waitForDrained) {
     if (drained) {
      waitForDrained.notify();
     }
    }
   }
   Event event;
   try {
    event = eventQueue.take();
   } catch(InterruptedException ie) {
    if (!stopped) {
     LOG.warn("AsyncDispatcher thread interrupted", ie);
    }
    return;
   }
   if (event != null) {
    dispatch(event);
   }
  }
 }
};

代码示例来源：origin: org.apache.hadoop/hadoop-yarn-common

@Override
 public void run() {
  while (!stopped && !Thread.currentThread().isInterrupted()) {
   drained = eventQueue.isEmpty();
   // blockNewEvents is only set when dispatcher is draining to stop,
   // adding this check is to avoid the overhead of acquiring the lock
   // and calling notify every time in the normal run of the loop.
   if (blockNewEvents) {
    synchronized (waitForDrained) {
     if (drained) {
      waitForDrained.notify();
     }
    }
   }
   Event event;
   try {
    event = eventQueue.take();
   } catch(InterruptedException ie) {
    if (!stopped) {
     LOG.warn("AsyncDispatcher thread interrupted", ie);
    }
    return;
   }
   if (event != null) {
    dispatch(event);
   }
  }
 }
};

代码示例来源：origin: apache/tajo

@Override
 protected void dispatch(Event event) {
  if (event.getType() == eventType) {
   latch.countDown();
  }
  super.dispatch(event);
 }
}

代码示例来源：origin: org.apache.hadoop/hadoop-mapreduce-client-app

super.dispatch(new TaskAttemptEvent(taID,
    TaskAttemptEventType.TA_DONE));
   super.dispatch(new TaskAttemptEvent(taID,
    TaskAttemptEventType.TA_CONTAINER_COMPLETED));
   super.dispatch(new TaskTAttemptEvent(taID,
    TaskEventType.T_ATTEMPT_SUCCEEDED));
   this.cachedKillEvent = killEvent;
  super.dispatch(this.cachedKillEvent);
  return;
super.dispatch(event);

代码示例来源：origin: org.apache.hadoop/hadoop-mapreduce-client-app

@Override
 protected void dispatch(Event event) {
  if (event instanceof TaskAttemptEvent) {
   TaskAttemptEvent attemptEvent = (TaskAttemptEvent) event;
   TaskAttemptId attemptID = ((TaskAttemptEvent) event).getTaskAttemptID();
   if (attemptEvent.getType() == this.attemptEventTypeToWait
     && attemptID.getTaskId().getId() == 0 && attemptID.getId() == 0 ) {
    try {
     latch.await();
    } catch (InterruptedException e) {
     e.printStackTrace();
    }
   }
  } else if ( event instanceof JobEvent) {
   JobEvent jobEvent = (JobEvent) event;
   if (jobEvent.getType() == this.jobEventTypeToWait) {
    try {
     latch.await();
    } catch (InterruptedException e) {
     e.printStackTrace();
    }
   }
  }
  super.dispatch(event);
 }
}

代码示例来源：origin: org.apache.hadoop/hadoop-yarn-server-resourcemanager

super.dispatch(event);

代码示例来源：origin: ch.cern.hadoop/hadoop-yarn-server-resourcemanager

super.dispatch(event);