From c1c61f7cb568ef6ed3fa47086e5b63e8e9ac9608 Mon Sep 17 00:00:00 2001 From: SisMaker <1713699517@qq.com> Date: Tue, 4 Jan 2022 15:14:30 +0800 Subject: [PATCH] =?UTF-8?q?pf:=20=E5=BA=94=E8=AF=A5=E5=85=88=E5=85=A5?= =?UTF-8?q?=E9=98=9F=20=E5=86=8D=E9=80=9A=E7=9F=A5=E7=AE=A1=E7=90=86?= =?UTF-8?q?=E8=BF=9B=E7=A8=8B?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/eFaw.erl | 16 ++++++++++------ 1 file changed, 10 insertions(+), 6 deletions(-) diff --git a/src/eFaw.erl b/src/eFaw.erl index a02c344..8aaf697 100644 --- a/src/eFaw.erl +++ b/src/eFaw.erl @@ -70,12 +70,14 @@ inWork(FName, Work) -> FTaskLen == FTLfl -> %% See factory if need to hire hourly worker %io:format("IMY*****************try addddddddd~n"), + fwQueue:in(FName, Work), fwFMgr:chAddW(FName), - fwQueue:in(FName, Work); + true; FTaskLen < WFCnt -> %% See if need to wake up idle workers + fwQueue:in(FName, Work), fwFMgr:chAwkW(FName), - fwQueue:in(FName, Work); + true; true -> fwQueue:in(FName, Work) end. @@ -92,12 +94,14 @@ inWorks(FName, Works) -> false; FTaskLen == FTLfl -> %% See factory if need to hire hourly worker + fwQueue:ins(FName, Works), fwFMgr:chAddW(FName), - fwQueue:ins(FName, Works); + true; FTaskLen < WFCnt -> %% See if need to wake up idle workers + fwQueue:ins(FName, Works), fwFMgr:chAwkW(FName), - fwQueue:ins(FName, Works); + true; true -> fwQueue:ins(FName, Works) end. @@ -114,8 +118,8 @@ syncWork(FName, RetTag, Timeout, Work) -> false; FTaskLen == FTLfl -> %% See factory if need to hire hourly worker - fwFMgr:chAddW(FName), fwQueue:in(FName, Work), + fwFMgr:chAddW(FName), receive {RetTag, Ret} -> Ret @@ -124,8 +128,8 @@ syncWork(FName, RetTag, Timeout, Work) -> end; FTaskLen < WFCnt -> %% See if need to wake up idle workers - fwFMgr:chAwkW(FName), fwQueue:in(FName, Work), + fwFMgr:chAwkW(FName), receive {RetTag, Ret} -> Ret