|
|
|
@ -68,8 +68,8 @@ closeW(WName) -> |
|
|
|
supervisor:delete_child(eFaw_sup, WName). |
|
|
|
|
|
|
|
doWork(WName, Work) -> |
|
|
|
toWorker(WName, Work, bind). |
|
|
|
-spec toWorker(WName :: atom(), Work :: term(), Strategy :: rand | bind) -> overflow | true. |
|
|
|
doWork(WName, Work, bind). |
|
|
|
-spec doWork(WName :: atom(), Work :: term(), Strategy :: rand | bind) -> overflow | true. |
|
|
|
doWork(WName, Work, Strategy) -> |
|
|
|
FTMax = WName:getV(?fTMax), |
|
|
|
WFCnt = WName:getV(?wFCnt), |
|
|
|
@ -95,7 +95,7 @@ doSyncWork(WName, Work) -> |
|
|
|
doSyncWork(WName, Work, bind, ?WAIT_TIME). |
|
|
|
doSyncWork(WName, Work, Strategy) -> |
|
|
|
doSyncWork(WName, Work, Strategy, ?WAIT_TIME). |
|
|
|
-spec toWorker(WName :: atom(), Work :: term(), Strategy :: rand | bind, Timeout :: integer() | infinity) -> overflow | term(). |
|
|
|
-spec doSyncWork(WName :: atom(), Work :: term(), Strategy :: rand | bind, Timeout :: integer() | infinity) -> overflow | term(). |
|
|
|
doSyncWork(WName, Work, Strategy, Timeout) -> |
|
|
|
FTMax = WName:getV(?fTMax), |
|
|
|
WFCnt = WName:getV(?wFCnt), |
|
|
|
@ -245,7 +245,7 @@ inWorks(FName, Works) -> |
|
|
|
|
|
|
|
inSyncWork(FName, Work) -> |
|
|
|
inSyncWork(FName, Work, ?WAIT_TIME). |
|
|
|
-spec inSyncWork(FName :: atom(), RetTag :: atom(), Work :: term(), Timeout :: pos_integer() | infinity) -> overflow | true | false. |
|
|
|
-spec inSyncWork(FName :: atom(), Work :: term(), Timeout :: pos_integer() | infinity) -> overflow | true | false. |
|
|
|
inSyncWork(FName, Work, Timeout) -> |
|
|
|
QRef = persistent_term:get(FName), |
|
|
|
FTaskLen = eLfq:size(QRef), |
|
|
|
|
