diff --git a/src/eFaw.erl b/src/eFaw.erl index 5cb7033..69c6b7c 100644 --- a/src/eFaw.erl +++ b/src/eFaw.erl @@ -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),