Flink 1.10 本机模式（DefaultActionSuspension.resume()是怎么被调用的，想知道这个调用的过程）

[thinktothings]

).Flink 1.10 本机模式).方法org.apache.flink.runtime.io.network.partition.consumer.SingleInputGate.queueChannel
  调用toNotify.complete(null); 直接调用 org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.DefaultActionSuspension.resume()).上面resume()是怎么被调用的，想知道这个调用的过程