# HG changeset patch
# User cin
# Date 2013-11-13 10:03:00
# Node ID 5a35900264f5d7a3e7a5adf452791da58790804d
# Parent  6a56df4ec59e8a1fa1f783feb68fe3527d129070

implemented nonblocking wake singnals processing

diff --git a/Implab.Test/AsyncTests.cs b/Implab.Test/AsyncTests.cs
--- a/Implab.Test/AsyncTests.cs
+++ b/Implab.Test/AsyncTests.cs
@@ -103,15 +103,15 @@ namespace Implab.Test {
 
             Assert.AreEqual(5, pool.PoolSize);
 
-            pool.Invoke(() => { Thread.Sleep(1000000); return 10; });
-            pool.Invoke(() => { Thread.Sleep(1000000); return 10; });
-            pool.Invoke(() => { Thread.Sleep(1000000); return 10; });
+            pool.Invoke(() => { Thread.Sleep(100000000); return 10; });
+            pool.Invoke(() => { Thread.Sleep(100000000); return 10; });
+            pool.Invoke(() => { Thread.Sleep(100000000); return 10; });
 
             Assert.AreEqual(5, pool.PoolSize);
 
             for (int i = 0; i < 100; i++)
-                pool.Invoke(() => { Thread.Sleep(1000000); return 10; });
-            Thread.Sleep(100);
+                pool.Invoke(() => { Thread.Sleep(100000000); return 10; });
+            Thread.Sleep(200);
             Assert.AreEqual(10, pool.PoolSize);
 
             pool.Dispose();
@@ -244,7 +244,7 @@ namespace Implab.Test {
         [TestMethod]
         public void ChainedMapTest() {
 
-            using (var pool = new WorkerPool(0,100,1)) {
+            using (var pool = new WorkerPool(4,4,0)) {
                 int count = 10000;
 
                 double[] args = new double[count];
diff --git a/Implab.suo b/Implab.suo
index aed3f9f75a5a4aef0daf4fc2d1945603eacc7f9a..2e658bab65aab728cc1f2d27570c91f2140bb05f
GIT binary patch
literal 75264
zc%1D$4R}=5l{Y{jAPQ1M#J`A<DrSb6WPTEm!eo9R5+INeC<ftW@-i8jWX73EAc$Ij
zTCLX7O0`O>Q1S1pR$6QQx3W~Nc3ISJ*{!YHTDM*Ox?PukRzBBOv*+CR?#!E)H}l?|
zpD+XS@}0b&dGDTc?>+b2bI(2Z+&5l7^_}niXx1Ny>i7Z~OFkQ(NX9FkjRB}&H&dni
zu>hY94-d1)R{{)|kCHh)1sDf)b|ye2zytuS^N9de04D=X0yqg^vQ+Kl6o4rJGXYKo
zm<I4Ufaw6I0n7k69pDUrSpXJ*dVsTJUO5NOjR4gE=K;(HI3J(}-~xa-0G|iA5a1$!
zxd0af)B>0Q%mDKM>Hw?&Hh{AM+yHg}2Y?fx0bo7Ae1HW2mjEoJyiLd=fW-hS0h$0j
z04o5z06u^v080Uy0WJkt2G9<$9AFJV3qUKtDuC4hZ2)TlIsh&MSO*{gd=X#+KqtUP
zfXe~=0Gj~53eW{0%H?vSeC~mB0H7Bj2yg|!W`GbtA3#4q7$5==1;9Ft!8r~v05Ax!
z1z;<{5WqHos{pnGTn%syz_kEhqO^zMFAjC#g>>VP9)4l`m;qeFc&SF`-FF_|vb^J+
zLlr197CWV9t$;BMIcx^(J#givRP*2;lOk`7em7M<w?i$(pmbZHq+^i(HSk{qn%MK0
zPC7MYOa-<99{eans}lHwP>-z?XH2F+gtG9%e-FSQaJYqXzxFW~@MF9Eyi9`;{3y5C
zi^y*XSSKh4DizNdDBC~E1J?er3|aff_ogep#rBW#fyn@rFWCOEonrexml$jR3*<Dl
z+CR2YZ2y-k@Y>~T*8Y|G&}#oKBDH^%9Vi1>`^R>|+CP4a?Y~8l-b(p;m3+qb-!5OH
z3|K2)e^EYPCZACjpbXe3-=mD^lCQf-vi;*(+5YjqPd;NG8<wwsLZo(%?LMxcZ;Rr3
zn|!@pK3^lBzXa!RKREZJ11A59C+8k?f9;``_w;y2eH?L5<ozV|z{Y@#%M^>r$eovW
z#5`ixK%g}$#>D=(5D$j?TLu4SAt2UPcZks#+%L3R%=E9e+C3184@AX<{o+78DuimQ
zTL-#ALH{yws6D({>|fYrsqeA(ID4$tZo5UO7ba9N%y^6&SRV98!?AEr+}sh24G5vO
z_&|3sY^Edx#AxE8Jsb|L4fc13x5UgIAuhBBBQbMpu)kmE3W@Z_yEQKM$AVqKP%u7Z
zZbeFC@Wd}(+(IwJD1O%#4@X7J=SfL@Du?2$Cdj|@p^sS$d=Uky)d_st2XZ9@Qml*i
zJ$Ou!-&f*98Pf&a6M#RIL2KcQI7pvfxYLt;gyQCxzo=hKPlLY+Km-~#1NC9xe(aMn
z(QzTjKc*uX#g95pZ5sU8|Df!R0Nx-_(63Vpa{&JZa+*f*SCORrSL655Ja>aW5r(Hx
zN{b$T#9PIIA6x8-G1B!oBOe$zFr6<E#)nd`9)SM>@L@I0Rfuv_HPqNvkjxIy>^ec4
z3PKL?-55X*)k8XHFE{{ShTyIZo(({GU|m$xzR(QN32(XKKYkmBbBvZ0^7+?Cod#?#
zA;8c>DPWYa`{JQUdRhz=1*v`$qVJ0d>6HC3CeP1!j$Gw8>QBp|Btlf)U?~cerw6E3
zDCx$iwTz{2FQ8+ctDv6j@MnRu6`%pMq6Qf8*r2vd@ZSYe#R6B2aBqcs{1xB#!L=Kp
z3EuU=8+Oog(#xMAsIM--AIeDooGj$O(q5p(za0Me(Ozr_`XY&zFpOr>N#R<+kK;Ym
zOO4{kv1)r7{M!AGl9JTJ2J#ojyt6p)<NHkhV}BE;nEPo<O13~&`y#ZJIMiF1(juyQ
z#QA_9_46}0@TZo47}6hrGM7?T=CqZz_h81J&;s};629>d>fEPP>*Hr*F%Oj=f@WG~
zz<&xSer5jKD2ERu@+g&a58MT4|0^VZ(LQRk;D5A_%#;~mC2-#r!1XAD)pguKM=+U>
z*^qzaXB>kW#gF<DlY3?;>n$p|vyy5*OzI2|FQA&EwrrBP6W^_(<F<UtrUjH!@|mKU
ztOklhw1p#YZHKS>LDE#io2|faW~lk5ga+IMZ*~)<^j(y9dXn;omlmlfaDxPCfK(8y
zlolJQ2MjKHWdkg3xM~7g9HfpubHf?Gasq`e`0oH}9F!J4PDo;P01h8~k11Iw2Fz;{
zJVOi(^r;C_M@pQu1U&GD6Q0)tIOyA0N=C7|@{Tnhe2`Cia^(XHq=t2Bq4n87X=#8z
ztIQEz_|imab;7j?-tj^D$i?-54>`aEZ@4*Y1TDMxm6h@sri5+44tTwgBOm2CqzQS`
zt!U9mjR&s1WK}iVUGvGul1`TIG?}#YQ@wdhVw@dJ8D|Goqi&?c!}U#s%GC(%_ps+d
zO@L|0O`ItSwEqfGJ`X9<L9K<Q1QbsC_^+)W`EGjS(mSVrd1K46Yb)7XGjF@?&^C9c
z=gF>?+V^%19%aub*Z!aXMPdKay<2Vz{OlFs4I<}MozBPO-y45j?|-{*zh?O5vHPxg
zUhBOY$Q4?kHv{bg%~gz!EiCY7rDF&y#mVwzh8o!ll(W8a-RqO+@0i1gY(>RdLR|&z
z3>`X_k*4Lo_A_bCu7G-Pht#F9keDdtT1bOgXA$Q@G6>~|lrdY17t%0Je><(yIIRyC
zd0?6}f*Ae`|D$EJh03HjZF8szv{Q{ZLa9Lvs2>i&uRZV=qS}&}(2&?@9<3`Z$7|?l
zD=b_0!!kc~%ip*uT`{U{1Zl3*X`0#x+P~4Ri#km<`WMq9P!Gm33RC?%D$Ad^j`f4$
zr#9hg4*X~<nlCFrSUQMRpkvW)m0qK70h^uU_-84UdN;-04|xv3e;=)*Zkgu_jURg!
zKX6Ha=6itZ-Ys%@WYW9Yk<IuIdkvdBa851ncDNg$+|TBNqO@J5*TG@@LFXm1&HqZO
z`%CQzA)w$q4?KzLq*aqe{%;02GEKTxOFyH0&yKUQz>o8$7s}V_`L8z6F~YR(@zatq
z(Ehpc<6JNs|N5vFU;&BhmGy{vDl<`svQqu1o@`8T$;i@~p9OxLd#byZ2S4@;%i(tc
zWK?R2II_Tx8rxF&Iurk)Otk8xh4L5Y)UdBJiXU^p>=?;D184ZWwEbh>(nfm=k@kgn
z)SY+U?n4zyYgd!I&3#JZF5CXA(rUJt<xFDgNDa=9W$v|;clpzL^D!dGrxu>;h@cMA
zs|U<pxX00^39jns_ycLN0u^>TI>FyORBLzAHyi2bqz>Mwqj!8Gf_!4lM~&o@o?L6h
zMXB*p3|@K6<fMGTWQ{al#NTj?f;yy&jw~CgwL#*R`ji^c9|<6BTN9%Zoc%UFijclF
zQ)v{VGc7EY2Ch^_eoy2tahy>3N9(-6yLY(uY*@Q^=YeT-LK)RF_4q+OzW77@v-{jn
zy>aSev&f#;rVRfqoxD?jryjqk@o3SbJe2RTXUS2P8R{%bW!(_fX9Q|N#piC|4MEn}
zyP-e9-ekQ|LDxm6Yeo*~*q5j-wo+vxBoBZrOU4au`{3=pYkv9XM;|`;Y5)cNu<9U-
z`S4>m+(%UfQO2_K-5Wzs^zR+qckVY9+_YfIvsNuE%5e{ldSXyEI4Wr;oA~jo2gfct
zd=cq%1$He=b(H9vbdqJ~<4aBrKl1Xr_0yd9hR0~rr`4+2fdk?mI!6<t{j7(|@io-{
zq%+t0OUEoo`?SUnzxrCsj%~kp@Bhs!<HF6;v}lhhK9J_2TMYM}U1VME^s~xL<-SW=
zp1<*fxznyVu;-G;{`&PF>>sa1dx*5>ihntj+bXCWk%EMK|H7&p_J7ptSae6|=%u%Q
z7?_}iTSE70g+u_GYrrH2<ZH}a1pe4KsFRM2{FH#sgkIALeMTMa=W9~PMH!8R)+Fo&
zW~y7((_W{BtbnvUwCDudr2MMvnl-X(&d}UniM=+a<CR7Cyw<q;!+-4?|Is*&OtT}|
z{w~k8{5@0}L=v4}DpB)J-hSmK_o8$6yz|-F<n0SSn61shG1_R6^}SG9lH~y#MnJ*Y
zIBVt`!P%|G=}#wu#FQrFdu;GvVBU|{KQZQL<pUqBU;jBRij#tHb*|;tMyHyj$v=sL
z!PmAO@;&?b<KI6#9NHA$y-TYi6A1IczfNkcwjE>s{ofhpzCYc)`?GyNzT<*N#yz)4
znQfH9T`BiW9{(c8{4;GNMLz&}v81WZU1MMzg5@Xah)(#=UxM>__@@odJqamy^1OND
zmpwgs)tyHUe{kTPeGh5!i9Bw8a6#|;PamS5QmF_%Joq(aeXbn9(f=^huZxNb*(}7-
z{?w+|bQ0i)yZ2n(wBvUN?%40R_N~8>Cnjl?YvMq&)KU%e^TE3&fAYYyci&gv_KACU
ztK*1fAGDc2|4J#gk_yWx{e39$T*CjOdo3T&JGjO2)cw!-CcZjjuO@edNC&*yE>|Xc
zdu#<J!z2f3ed=4G(Ed1u@Y&zc_n%oEQtf{pngvN9in_KpJgUi<3iSD%O0u&*>)BuG
zbkeGk{qK14kG}ZKiqtOKSbPcVYtq`8I`6>j^3fEZ9Q6NCD)vV3qrc3<^0iU|KU%qa
zc5_=**IPR_?0xo=BY(*xftmchG{^Q!GbN!vGV!gN53Yas)21I?zx?T)&KIkQX1hy8
zxFWm$e~qkeuqRfThQB;?xNG{+ldHpfpMSINh09OYY&FUwlSKpthl}!ckTz5|2=4%q
zd?nCdDZM>mflN+BZXFNJa0PDoy_Wnwlw<$b2KRos6%Nw52>cQ)F9EU){_Cv<Vf;Un
z6sG;v>*J?ZM;`vi^*UcRh~K7<zXI1Vn2GWH<GLXxS@rF|nJvI`vXDP0SJ|BQbpY3s
z)b&SSk<T~F=Ud=>t9*T%eBJ@)2LQeaa67<GfNufZ0dOb4w*l?~xLbbzJ8=Fkz&!x>
z0_+CZ1Moe7`vCR=+%LcTpnQH<KC|Odxc`Cb89RQgc&_z39?#3~{8T>gm(K^%q^Ugq
z8QwVv@GpvYapL<;fM4o-{~P%Iw*YS&z*9cT$7mi_I$L3d9!I)j`VOkA5qXqL`!$uL
zG<MD?wYub4on$|OsiHS*n0hvLs;v0hDy=k5%9M7xbqY(GTAEQt^Q$4*7!wiO>IAl2
z#@yNXo0vyX=K>sYI;Yk}`w=lQ{6I=gS(VF3^-ODcgXz!7Q~JpiFV3MRnORzkT93D-
z8Po3~yel7&dwXbFY*l8psumdMj9eqpsZqO`YQ8g3)1B1+URn#<2T#_)|4^cxDA#cD
z*K;QTY8q1Bn%r%z>iLmLla1Ry($|eK{WaSZ&50KG*n-pIKizw%g3U*#*Q(i($(}FG
zgEMKUmW#u~Bjlp$$Rrmf8zz&BNjlZ}%uO23<1FK3OArlNVi5;_Ju*L&)KP4R)?l_0
zi*G`LU%ud-x^&QHhjOcjwtFS*)~w2%zyGo1p^P#c?MthdJ1?tpPo2cXbS~sf2j_3m
z@);mWzrm5I@^YNfDK7s0SDo|ZI5U~zIh-k`8l<zKshN6JNj+;wei}+i(VT}8Oh4;@
z80O|I6_(OGbdQi{ygX%0O3u!b-rRY<gO=+6wN0e&9r$}7zG-o$&21_fZLSYe@zdv0
zPo7Sb^OsDHQuR|ek^HvP<?Hei&DY4>Fy1Te9HADge4Y{!0&<vyHaCtC)E-ms&yYq4
ze6m?-fY*MWs^iyO7TWY*Z;kXi#kro$zJW^JIRbg^qVg1V3Do!7;cFLN=YvNkeLq(_
z2(FAUW(P@@KyKPUpJr~%B?8l}%{txmqw`YKHXS*Z1E0Rnq)jd({PaARlx`Sp=_=9)
ze@)aQ)<f6qp{KH&u5d(OSs!f|xQfw5*Y=s{idGNxQFYO^bWQZDMtN=l>Asa)N@gEv
z!cDoXkJhh~<`u{Fh<QMku71Pv)|`S<iP20oae;mvr`n06O(Kt|ClyEXVY>ctQ_1uu
zWlg3u^OatcDWq({-c$LUs7kXeAGGBI_A;Y~RjorDFKrjs1!})hp~`V-w`!x>e0CP{
z$wX-(U%;U~Ygo%Uv}Y-%j=r_LtT~r8=k%I$xraGXHBes5JJW0Q=H&`GUOHZS-s4|u
zE);i_HRiI$Jeut`*Yzv>>pwEjJ^yOf(4)Iv5Ei(4_Wk_jx9{nZBG5?(mbTId9aHTn
zjB54dy<-o*`Kxa|_0ChjoO|OF@6FWm13$Ctn(2Ev{NME^V5g1youg~=Y5(@`hwuN>
zSG?lTSPh&bH0-9_Cjvh{DKP8s8~aY5@sr2T9V7nwsFvS-3JppPn{)jupR37lH?OGt
z?fj>^)|@e6_M`P@-=ejKCPy8ZWBq`U>Cb<By6Mj!wV3u?e#5I*JYo(ltkkMQCBlPw
zSihG``z?={jm&?kBLw`qR+|6f^BiFQidr79%6YH(=0>_&Z#3q;^w%F)NTvhVADl^~
zJsVPlLxuxK;$it(@@&L@0;5n#-Zaum8Y9uyrS%u+4>6qsKiUXb{2~4PXI_DV`NzF0
zY#jI>0k}!N?f`tPfN3@GK`X7DW$=FqJZYoQ2Hdie?o6Y7%*`VH5bj~a@;_q#g>iWC
z*NV2GSX}HgyThT7=*R6BV&)~deL>J~_5|qzAv(0F?y}3|7u({|V1J;tx-aGrM?=A`
z<Ted9!@D#%or2wOcUT+iZK9>2aYOB88dNM5V!d(PZy~?9Hehc%K~AU29qx+=Q88MD
z*xG{IL^76C-JYpX<g@q60RgvuU<qup7PN#m&}y8>tZL)%q8Q0U;!e_((%SofY)!Kx
zhqpg2MkCQ+OvJ4?VrF+ph{Zf&EEs@n<zr`%$;bxHQc>g~=arbN<=JG$?DlxKM#9m!
zCn$u%fu``*HZdNDnn6u;MkFc@2Ezlf(2%=V^luisn}OcgRQ9+f?5A6%oW&kA_Xz>f
z7moG`aeTA6zgyfoJv=Bzqrq;`yEPcYlzqXFh^>E~2LH50L_ZJ$EumZHkmRpeWK|Vd
zZ4;5W@icxYt<p-o=S_}A0qYjx!q~GkzH~*S!VvDIf><YFuQm?<>ApICV-Sm|a$^jT
zR&5-VY8FVXs+u@KAseT%o0E)cmAvDhOrCA`d!7+)UT!zP{Ls|xz3-gVn`s5EWS!^I
zU-jJ!BRhBWnO}Ny!>PB6fBwUFZZc~|oRJP`HsM(N&vV328o7QR%RvhJxrVx^r>+Hl
zX37h@#NerSR`zy3Vs3FfsSGoD7<lUav5LyccKyPM?*Gpbzs1-xf=``)-*;<o^}vfq
zw=W(y<|`j+uHa7f2+n2wffQ?DNnlmqq1`ig+vnL=oj&+|%~7BB?Aozjzi=$QgF>V<
z$B?P}l9*}ihA5qvIB{lI0wt3p?Ui&bv<|O4;ry3+OD11h)_gaOPmD4%a@^G%v+||O
zS5L|23*X%$TUXNMZlGjy$7+pTVf>_cVqYh;U@=S9i8DKTEPV=(KM5!85tsR0wSB%+
zrC|0xd?%6wIcG$v@T79Q@QS*}9LX!}jT2|~>iE+XrfAfv@;!C#kKa+{X(LJ^{Wt1T
zNf-HK5~->t<aBa(g=fA6{;u-b?G~Ta*I;UJ+8idE%VRM$I;=KRgWc}4xou5OpT&Ol
z_U67wNa*U6PG)~B5)EIm-9Nu`OE|i@GbsHipCUq32!+H@tg|~9iwJRlZzLQJ!8hBt
zU*&SRoi>}R!DR8;Tqc{(?JzYoI9w)+!&cW&Z?W4PPTSSrWu!UkeT{W)i`(R|Hu+4p
z2DioJs&_g~4IYQnUGH`{tR4#^&D<`=;+=}?j6|B___h!m>i6SSjDxyc3RiH^a9=Pc
za?tYaQK&@xQH*j{;a#IZn1JT~cvJ{-Ro|VXK^gKDXNi4l6zJ-UUpb&Z|D8DkVmA9f
z4U%O1L1xfpd+fT2v>$69Tr-bu9sCu`;Ea}0qxhBaC)N0u5NRK*ND3wCj|+3$e@l(O
zjY{yiLF~Ejzbp>$2$;fgWe|P~M8#OFKO7JC1jQ%^Rks(8s<;r_><{<Hqd2d~L(?}4
zMpK{AF9gJH{@$T*BxPMnI|^5GexctlhC=8m!a>lj1!Zu~3M*i*DL1xYe=sf%iv4jR
z8sO<Q3&%=>LTEtDhNPW^7froFe|NF)x6DnkxDe-IsokTcOUv~2ilGQsi6xYMi^J=*
zIH1HF4GmV4t=`*YYOHg5O+KI7ZmD<q9IhsJf<WKa&csz_;(E4r3jM)8>K-Ez$HQd1
z3Qt{1!ST@c14dh&uiomlS?nfnox^FeSsU#pm&NWe*_}2^W4*i1T4!lg(3VoW@~s|~
zQXR(xxEDLok0>Mz^@O8+9OQogSdrT&1p7H@-BrkD4AmSDia1J$iG5w6A*7CjwhB_g
z-2Z}$i+B`&I`I_KP+6@L&!olJmN1*l+kZs`+C>QQ6z||wI}<l2?rZmBcy@G+_7pK^
zXy-zC+$Wzsqctk#8x?71K)G#T4a-1r+p@GXvNm!5@r$^106Lg?igC=P&q(O4cpj2p
zw3agMJj_YlpTGYSBKbjj@?yHu-~UE;{R6lC0r%cuRvmr(c0K%b{|hHEZvVlx7Xicg
z_4nVv{friJ;QuO-_T4asUw8ctclm#fB=;X$OCqFa#J)?oORk+X5ZnRRMbGJuxsZS4
zNZeD~DE@B%Y?fQ*YKqxQSLNcIc39IZIQ=mb@MEW4%Yk2M|8i6B<*g(l+ud+=D*9uF
zX-(h^YFw@t?V~n}{a1D&$obc=e@Di&vZ?=vNV5K$WFJ%Xx#(BrSa0nW9=QJ&YDvt^
z)(HOj0F&fvz5F-oq?OJ7TWC?;Xb^vc0sQz5+g8>H{s=(OApSai`+EiY*0XJQjo`n5
zNPCdsQS7s#sXHIw+5)ZL)w7+)n|JEeH2F@xnQjGZsl|N4eZ=%*K9zTkDO{YU@~$x_
z#;!5Pub)hL^+oaID7)1c<=9=LRVM{-T~T+ok_jUbaDbe@pP4fXXwS>VpFleU%HtH4
zfg+sd*QdTp2G5QPkKXvhsZLIH)MPRK#FjE3U+eoHWgY?I_y>0}K`WI}{Eu_suQw3?
z1o1B7z`u?p{h##5f4cc6Um(($+9>|#NOJsNT<#ZYN=Nc8jxJ^Zc#3kqU!Q)oK;!tS
zfRcmDeqLTNSgJjDepU?XbMNOBPjJ_2x^sEa`;q9k#HsSxQ*=%``m|#mpuNUZRQ_uE
zbkAgEUc9bt`kBBk2;-s@P=sgg1*cCvdIO-4@JLQArM`b9SNt3OEgOH{eEXOU|9RUZ
z5BKekPH4UF4$T;xN=s>bA+{5Jde2M4mrOZ(+da?zeeA5K#n&~dkjA=P@kcc_Th!M-
zGmijJ|3!xYFEOrvzCcLA>Z^~xE>lto{oBHU|3$(x|D1USXigUMPyYn4#UTEA{rq!}
zzc8BMwd^Lj+2*rvOuFwIFI7G`@W;Qc@gBJI=bBunK33;{<IJ9p$%h|%_ri;IO=!61
zHGAMcG^6RTqr87@Zu{33r!T9T%cO4X)WrRf7cu52j-x##=Ju+cv$2W$sr%0$(rPBp
zsCdX8>-~#g$wT~O^bu+trRe49qH{g4ZRg}$FZ%S=u@B4|zUIkwdoo4tQ|b@7h7UiG
zWBKX#Kl=U$y#3EF0RARl>*Lq=|5{9W)Oi2@I=~Ub_;ve#?*8{JfKLqL*SCLq;JlO=
z&wnSt2lDl3w;wH8@bo9oUA181$K-#WdFJK2Jg0>+#r#+2rM!Q6Zu^%Pr(LTYF>16T
zM&-JHeLnUtuv0I`h9cN~WcA5!Hoa+ge(nAEnhVxeZhkVeB*GCmZ-8Aa)!A9L*W7jf
zksDa#X@!(pEN4(_i+hEic1Dsu@JC)mk2%bYr<hlTX=g)upo`ymB%#f!cP^CVO&7Oc
zl`_0?8*P~p%Ky@M6D2zH*I{_3a^lI(^2nHxM=r4|E7=G*rM@=^c|=*_BIqrKGfON#
zCc0M!29MqbZ$&7bM!u0Go7K?!EH4-nX?<S2=!zv`;IZ0I?f9GBEJq70M++=R3oJ(q
zEJq70M+?k%w7_C7mGWw#+*S**{q8FNXq^{$_YT*d4Qm(gJTPtIxOvikciF6&QH}^Q
z{hGQzO4S!^qqYa0_DUwn(IeZHOvA&tB9^UW${g2PT@JaeYg(9N9i@)iR#H1bl)gQr
z7>B4=442}}E1$<pcH>*bGrz!i($_^cYq^w|Q)@r9rDnT^j-S^Uw#FQ>Wn(uOjfnQi
zRVhAVhd&FPtpE*l1&R~6+d)^QxabNLT&d!qaXIl<d>_}QxB;5rT_3z*SFB1oK6>)f
z_1I0-xte4?NSCkj?(V52Szf!isbq3$bnRm4v|YZPmFlzTos9Mq%JuHa-ogUq<E0v_
zL+&kb7Oer=IQACxbp5`G&g?tk8rLxTfI>T+Lvz8k1O7L`lTu&9c%tu}l#6}pI{5Z_
zBE`gEpge9NQoIoCnJ{k9Z2(^f*g>Q?J{VxGn~ZeOEFYzD9DDnu)@;zR+&^lx<oF~N
z9n!CAYRVd+wnm6iu|^N8+Qw3<{bcs@Wu=<q@~lsJ)~7t{Q=au1IqOq85-qb02_>5L
z8|h|wN-ZYb*~EBExbiGYc^0KSi&Ct!D91++Q@R$-@@zzTHX@hVh-_rN5ntWWvTtuH
znVK>>n^O2liTR(CE**KvHv?3v`6|zzlw$6RZ!N`W^bTdKdD&`ytmS^$YF@UQmsak|
zR`aseylgek&1#NoBfRdm*21NHEJ{%?{*2AQ{%1?zd?_&=e+Jjv9F?#2@f(Z(#||U-
zQ8W42Fn-<r?<$&!w7T3VevG~M55xF%<1cZ?A431FPf{NR7pL5&4Huw#J-1jK>7&|6
zwg*ohqGU+18alEVm+0>gBZYx&%`pN;9NKY|?zYBK#SpEp=3(~7NL(lFd|_{JC=V1A
zPh=Nq56zaG<E_ONoQ3<|brvwT6YkE2(b7t*9?Gry*thCJM>`}0V;K3eD1SG-N4>?G
zNUJh0?Wi5vJZeV*jb@ojEw079JZB78qxcN%Ab3XWN3wn|0C>qzI$AOCq~3KkSBWO)
zWRvwYGLFxLjB>9w%XX9+;Yzz5;d<MHdEj^}-38Y<N<5!Qe$C}9t>UkL{rHpm@xOfp
z_mMTO|Du1<b@H`7etrFW0i0bN_}3HT@yF{6u>bBRBCV+~g5PFv{~;dyxQhpiKh6^?
zig6U$;NK{@cCDu$UQBBye>)RsW2qs0eced^8<f1=1Y<U@fj8OnWN(UlgYd~HquUY?
zf>F15`_a^to8?)9^m-E7;&?QR&J0=#dj0Wfa{60DNdAcJIhL?i#7#oZB7}M@<Q5HH
z@@(YGw|?YGLS~U{qRtuhgp+pF;~Sx6j=n4H6qb+i6Z$(e032)m<061dxJoEB!Z9He
zIi<tMI#kd5B_$8qh<ZoKlTq3YfUgy5$?G;Ed3*|rQpTvNZ|8w)PK5Z8W&2UtepI#}
zmF-7m`%!-EN2OK2+Lny-37;jSla6Eb_0P|7wku;=3r=*c%QDsU(txEtle4Ey$2sZR
P(K(!2kXd0N!gT*1Qma<E

diff --git a/Implab/Parallels/DispatchPool.cs b/Implab/Parallels/DispatchPool.cs
--- a/Implab/Parallels/DispatchPool.cs
+++ b/Implab/Parallels/DispatchPool.cs
@@ -83,14 +83,42 @@ namespace Implab.Parallels {
             return signals;
         }
 
+        bool FetchSignalOrWait(int timeout) {
+            var start = Environment.TickCount;
+
+            // означает, что поток владеет блокировкой и при успешном получении сигнала должен
+            // ее вернуть, чтобы другой ожидающий поток смог 
+            bool hasLock = false;
+            do {
+                int signals;
+                do {
+                    signals = m_wakeEvents;
+                    if (signals == 0)
+                        break;
+                } while (Interlocked.CompareExchange(ref m_wakeEvents, signals - 1, signals) != signals);
+
+                if (signals >= 1) {
+                    if (signals > 1 && hasLock)
+                        m_hasTasks.Set();
+                    return true;
+                }
+                
+                if (timeout != -1)
+                    timeout = Math.Max(0, timeout - (Environment.TickCount - start));
+
+                // если сигналов больше не осталось, то первый поток, который дошел сюда сбросит событие
+                // и уйдет на пустой цикл, после чего заблокируется
+
+                hasLock = true; 
+            } while (m_hasTasks.WaitOne(timeout));
+
+            return false;
+        }
+
         bool Sleep(int timeout) {
             Interlocked.Increment(ref m_sleepingThreads);
-            if (m_hasTasks.WaitOne(timeout)) {
-                // this is autoreset event, only one thread can run this block simultaneously
-                var sleeping = Interlocked.Decrement(ref m_sleepingThreads);
-                if (Interlocked.Decrement(ref m_wakeEvents) > 0)
-                    m_hasTasks.Set(); // wake next worker
-
+            if (FetchSignalOrWait(timeout)) {
+                Interlocked.Decrement(ref m_sleepingThreads);
                 return true;
             } else {
                 Interlocked.Decrement(ref m_sleepingThreads);
@@ -106,6 +134,8 @@ namespace Implab.Parallels {
             if (m_exitRequired != 0)
                 return;
             if (m_sleepingThreads > m_wakeEvents) {
+                //Console.WriteLine("Waking threads (sleeps {0}, pending {1})", m_sleepingThreads, m_wakeEvents);
+
                 // all sleeping threads may gone
                 SignalThread(); // wake a sleeping thread;
 
@@ -130,8 +160,6 @@ namespace Implab.Parallels {
             bool last;
             bool requestExit;
 
-            
-
             // if threads have a timeout before releasing
             if (m_releaseTimeout > 0)
                 requestExit = !Sleep(m_releaseTimeout);
@@ -242,8 +270,8 @@ namespace Implab.Parallels {
 
         void Worker() {
             TUnit unit;
+            //Console.WriteLine("{0}: Active", Thread.CurrentThread.ManagedThreadId);
             Interlocked.Increment(ref m_activeThreads);
-            Sleep(0); // remove wake request if the new thread is started
             do {
                 // exit if requested
                 if (m_exitRequired != 0) {
@@ -269,10 +297,10 @@ namespace Implab.Parallels {
                 // keep this thread and wait                
                 if (!Suspend())
                     break;
-
+                //Console.WriteLine("{0}: Awake", Thread.CurrentThread.ManagedThreadId);
                 Interlocked.Increment(ref m_activeThreads);
             } while (true);
-               
+            //Console.WriteLine("{0}: Exited", Thread.CurrentThread.ManagedThreadId);
         }
 
         protected virtual void Dispose(bool disposing) {