ft： 部分修改

include/eFaw.hrl

@@ -1,15 +1,15 @@
--define(wMod, wMod).          %% 工人任务处理模块
--define(wFCnt, wFCnt).        %% 固定工人人数
--define(wTCnt, wTCnt).        %% 可以聘请的零时工数量
--define(wTLive, wTLive).      %% 零时工最大空闲时间单位(s) 空闲超时之后就解雇
--define(fTpm, fTpm).          %% 工厂任务处理模式 fifo lifo
--define(fTLfl, fTLfl).        %% 工厂任务承载线 超过该值就可以聘请零时工了 0 固定工人数 工厂负载超过该值时增加零时工
--define(fTMax, fTMax).        %% 工厂最大负载量 超过该值时 工厂就不再接受任务了
+-define(wMod, wMod).          %% worker Mod
+-define(wFCnt, wFCnt).        %% worker fixed count
+-define(wTCnt, wTCnt).        %% worker temp count
+-define(wTLive, wTLive).      %% temp worker idle time(s) after to die
+-define(fTpm, fTpm).          %% Factory task processing mode fifo lifo
+-define(fTLfl, fTLfl).        %% Factory task load line When the factory load exceeds this value, temp workers can be hired
+-define(fTMax, fTMax).        %% Maximum plant load Beyond this value, the factory will no longer accept tasks
 
 -type fawOtp() :: {?wMod, atom()} |{?wFCnt, pos_integer()} |{?wTCnt, pos_integer()} |{?wTLive, pos_integer()} |{?fTpm, fifo | lifo} |{?fTLfl, pos_integer()} | {?fTMax, pos_integer()}.
 
 -define(FawDefV, [
-   , {?wMod, fwWTP}
+   {?wMod, fwWTP}
    , {?wFCnt, 30}
    , {?wTCnt, 20}
    , {?wTLive, 300}

src/Faw/fwFMgr.erl

@@ -46,7 +46,7 @@ handleInfo({mChAddW, FName}, _State) ->
          AddCnt = WTCnt + WFCnt - WorkerCnt,
          case AddCnt > 0 of
             true ->
-               hireW(AddCnt, FName, true);
+               eFaw:hireW(AddCnt, FName, true);
             _ ->
                ignore
          end;

src/Faw/fwQueue.erl

@@ -33,7 +33,7 @@ ins(Name, Values) ->
    [ets:insert(Name, {erlang:unique_integer(), Value}) || Value <- Values],
    true.
 
--spec out(Name :: atom()) -> empty | Value :: term().
+-spec outF(Name :: atom()) -> empty | Value :: term().
 outF(Name) ->
    case ets:first_take(Name) of
       [] ->
@@ -42,7 +42,7 @@ outF(Name) ->
          Value
    end.
 
--spec out(Name :: atom()) -> empty | Value :: term().
+-spec outL(Name :: atom()) -> empty | Value :: term().
 outL(Name) ->
    case ets:last_take(Name) of
       [] ->

src/Faw/fwWTP.erl

@@ -61,7 +61,7 @@ code_change(_OldVsn, State, _Extra) ->
 
 work(task1, State) ->
    State;
-work(task1, State) ->
+work(task2, State) ->
    State;
 work(_Task, State) ->
    State.

src/eFaw.erl

@@ -100,7 +100,7 @@ inWorks(FName, Works) ->
          fwQueue:ins(FName, Works)
    end.
 
--spec syncWork(FName :: atom(), Work :: term()) -> true | false.
+-spec syncWork(FName :: atom(), RetTag :: atom(), Timeout :: pos_integer() | infinity, Work :: term()) -> true | false.
 syncWork(FName, RetTag, Timeout, Work) ->
    FTaskLen = fwQueue:size(FName),
    FTMax = FName:getV(?fTMax),