opt: mitigate the latency issue by prioritizing asynchronous writes

Fixes #423
panjf2000 · Mar 29, 2024 · e2d2ee3 · e2d2ee3
1 parent f7cfb5b
commit e2d2ee3
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/connection_unix.go b/connection_unix.go
@@ -442,14 +442,14 @@ func (c *conn) AsyncWrite(buf []byte, callback AsyncCallback) error {
 		}
 		return err
 	}
-	return c.loop.poller.Trigger(c.asyncWrite, &asyncWriteHook{callback, buf})
+	return c.loop.poller.UrgentTrigger(c.asyncWrite, &asyncWriteHook{callback, buf})
 }
 
 func (c *conn) AsyncWritev(bs [][]byte, callback AsyncCallback) error {
 	if c.isDatagram {
 		return errorx.ErrUnsupportedOp
 	}
-	return c.loop.poller.Trigger(c.asyncWritev, &asyncWritevHook{callback, bs})
+	return c.loop.poller.UrgentTrigger(c.asyncWritev, &asyncWritevHook{callback, bs})
 }
 
 func (c *conn) Wake(callback AsyncCallback) error {