ResponseProcessor:主要功能是处理来自datanode的响应。当一个packet的响应到达时,会把这个packet从ackQueue里移除。
@Override public void run() { // 设置 ResponseProcessor 线程的名字 setName("ResponseProcessor for block " + block); // new一个PipelineAck对象
京公网安备 11010502049817号