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
The core of the thread pool is about the working threads running the tasks and how they are parked and unparked.
One of the main goals of yatp is to adjust running threads number intelligently to the work intensity. So we shouldn't be too eager to wake up threads when there are new tasks. Instead, we need to detect if current thread number is insufficient. This can be done by calculating the time a task waiting in the queue. When it's too long, we can consider wake up another thread.
The text was updated successfully, but these errors were encountered:
Hi, @hk1997, if you are interested, you can help us to solve issue #12. You can refer to the implement of runner for std futures. I think the two should have a lot of code in common, may need to figure a way to avoid redundant code.
The core of the thread pool is about the working threads running the tasks and how they are parked and unparked.
One of the main goals of yatp is to adjust running threads number intelligently to the work intensity. So we shouldn't be too eager to wake up threads when there are new tasks. Instead, we need to detect if current thread number is insufficient. This can be done by calculating the time a task waiting in the queue. When it's too long, we can consider wake up another thread.
The text was updated successfully, but these errors were encountered: