You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Curently we will keep polling when there is no free slot.
ifletSome(slot) = future.uring.submit(sqe){// ...}else{// There is no free slot.// We expect that wake_by_ref() will put the task at tail of task queue.// But Tokio will put the task at "next task" slot, so it will run again immediately.
cx.waker().wake_by_ref();returnPoll::Pending;}
I am working to remove the polling. I will save the waker in the free list when there is no slot, and invoke waker.wake() when others release the slot.
The text was updated successfully, but these errors were encountered:
Curently we will keep polling when there is no free slot.
I am working to remove the polling. I will save the waker in the free list when there is no slot, and invoke
waker.wake()
when others release the slot.The text was updated successfully, but these errors were encountered: