with all of the worker threads in our pool These threads poll the flag periodically and also wait on the event whenever they must block, ensuring decent responsiveness to any shutdown requests Here's the definition of F i b e rPool , F i b e rState , F i b e r B l o c k i n g I n fo, and Wo r kC a l l b a c k data types

II Fwd - d e c l s s t r u c t F i berSt a t e ; s t r u c t F i berBloc k i n g l nfo; struct WorkCa l l b a c k ; I I A pool of t h re a d s o n wh i c h fibers a r e s c he d u l e d and wo rk items run c l a s s F i be r Pool

{ II Threads in the pool HAN D L E * m_t h readHa n d l e s ; LONG m_t h readCount ; II A queue of bloc ked f i b e r s C R I T I CAL_S ECTION m_b loc ked F i berQueueC rst ; std : : deque< F i berBloc k i n g I nfo * > * m_pBloc ked F i be rQueu e ; HANDLE m_bloc ked F ib e rQueueNewEvent ; C R I T ICAL_S ECTION m_r u n n a b l e F i b e r L i s t C r s t ; std : : set < F ibe rSt ate * > * m_p R u n n a b le F i ber L i st ; II All f i b e r s in t h e system C R I T I CAL_S E CTION m_fiberQueueC r s t ; std : : deque < F i berState * > * m_p F i b e rQueu e ; I I T h e q u e u e o f work that n e e d s to be a s s igned to a f i be r CRITICAL_S E CTION m_wo r kQueueC rst ; std : : deque <WorkCa l l b a c k * > * m_pWorkQueue ; HANDLE m_workQueu eNewEve nt ; II To i n s t r u c t t h re a d s in the pool to exit BOOL m_s hutdown F l a g ; HANDLE m_s hutdownEvent ; public : F i be rPool ( LONG t h readCount ) ; F i be rPool ( ) ; BOOL void void void Bloc k ( HAN D L E hBloc kedOn ) ; QueueWork ( WorkCa l l b a c k * pWork ) ; QueueWork ( LPTHR EAD_START_ROUTI N E IpWo r k , PVOID pState ) ; Shutdown ( ) ;

I I I n t e r na l WorkC a l l b a c k * ContextSwit c h ( BOO L bBloc ked ) ; DWORD Th readWork Rout i ne ( ) ; void F i berWo r k Rout i n e ( LPVOID I p P a rameter ) ; }; I I I nfo about a f i ber s t r u c t F i berState { PVOID m_p F i b e r ; F i be rPool * m_p Poo l ; WorkC a l l b a c k * m_pWork ; F i be rState ( PVOID p F i b e r , F i berPool * pPoo l )