Parcourir la source

Merge remote-tracking branch 'origin/master'

master
SisMaker il y a 2 ans
Parent
révision
eaf95dceeb
2 fichiers modifiés avec 14 ajouts et 8 suppressions
  1. +9
    -4
      src/gTimer.erl
  2. +5
    -4
      src/timerWork/gtWork.erl

+ 9
- 4
src/gTimer.erl Voir le fichier

@ -9,7 +9,8 @@
, setTimer/2
, setTimer/3
, getTimer/1
, delTimer/1
, asyncDelTimer/1
, syncDelTimer/1
]).
timerName(Idx) ->
@ -51,6 +52,10 @@ setTimer(Time, MFA, Strategy) ->
getTimer(TimerRef) ->
erlang:read_timer(TimerRef).
-spec delTimer(TimerRef :: reference()) -> false | non_neg_integer().
delTimer(TimerRef) ->
erlang:cancel_timer(TimerRef) .
-spec asyncDelTimer(TimerRef :: reference()) -> false | non_neg_integer().
asyncDelTimer(TimerRef) ->
erlang:cancel_timer(TimerRef, [{async, true}, {info, false}]).
-spec syncDelTimer(TimerRef :: reference()) -> false | non_neg_integer().
syncDelTimer(TimerRef) ->
erlang:cancel_timer(TimerRef).

+ 5
- 4
src/timerWork/gtWork.erl Voir le fichier

@ -35,10 +35,11 @@ handleCast(_Msg, _State) ->
handleInfo({timeout, TimerRef, MFA}, _State) ->
%% Msg格式
{M, F, A} = MFA,
try M:F(A, TimerRef)
catch C:R ->
error_logger:error_msg("gTimer timeout error MFA:~p C:~p R:~p~n", [MFA, C, R])
end,
spawn(M, F, [A, TimerRef]),
% try M:F(A, TimerRef)
% catch C:R ->
% error_logger:error_msg("gTimer timeout error MFA:~p C:~p R:~p~n", [MFA, C, R])
% end,
kpS;
handleInfo(_Msg, _State) ->
kpS.

Chargement…
Annuler
Enregistrer