VerifyQueue: Add re_notify method, re_notify other Workers before che…

…ck tasks is not empty

tx-pool/src/component/verify_queue.rs

@@ -186,6 +186,11 @@ impl VerifyQueue {
  Ok(true)
  }
 
+ /// When OnlySmallCycleTx Worker is wakeup, but found the tx is large cycle tx, notify other workers.
+ pub fn re_notify(&self) {
+ self.ready_rx.notify_one();
+ }
+
  /// Clears the map, removing all elements.
  pub fn clear(&mut self) {
  self.inner.clear();

tx-pool/src/verify_mgr.rs

@@ -90,11 +90,13 @@ impl Worker {
  match tasks.pop_front(self.role == WorkerRole::OnlySmallCycleTx) {
  Some(entry) => entry,
  None => {
- tasks.ready_rx.notify_one();
- debug!(
- "Worker (role: {:?}) queue is empty after pop_front, notify others now",
+ if !tasks.is_empty() {
+ tasks.re_notify();
+ debug!(
+ "Worker (role: {:?}) didn't got tx after pop_front, but tasks is not empty, notify other Workers now",
  self.role
  );
+ }
  return;
  }
  }