एरलांग में समय-समय पर कुछ करने का सबसे अच्छा तरीका क्या है?

Question

मेरे पास एक प्रक्रिया है जिसे हर पंद्रह सेकंड में कुछ काम करने की आवश्यकता होती है। मैं वर्तमान में इस तरह कर रहा हूँ:

 
    -behavior(gen_server). 

    interval_milliseconds()-> 15000. 
    init()-> 
     {ok, 
     _State = FascinatingStateData, 
     _TimeoutInterval = interval_milliseconds() 
     }. 

    %% This gets called automatically as a result of our handlers 
    %% including the optional _TimeoutInterval value in the returned 
    %% Result 
    handle_info(timeout, StateData)-> 
     {noreply, 
     _State = do_some_work(StateData), 
      _TimeoutInterval = interval_milliseconds() 
     }. 

यह काम करता है, लेकिन यह अत्यंत भंगुर है: अगर मैं अपने सर्वर नया संदेश को पढ़ाने के लिए चाहते हैं, जब मैं किसी भी नए हैंडलर समारोह लिखते हैं, मैं शामिल करने के लिए याद करने के लिए है इसके वापसी मूल्य में वैकल्पिक टाइमआउट अंतराल।

 
    %% Someone wants to know our state; tell them 
    handle_call(query_state_data, _From, StateData)-> 
     {reply, StateData, _NewStateData = whatever()}; 

आप अंदाज़ा लगा सकते हैं, मैं कर दिया है कि बहुत की एक संख्या गलती की

 
    %% Someone wants to know our state; tell them 
    handle_call(query_state_data, _From, StateData)-> 
     {reply, StateData, _NewStateData = whatever(), interval_milliseconds()}; 

बजाय: यह कहना है कि अगर मैं एक तुल्यकालिक कॉल से निपटने रहा हूँ, मैं ऐसा करने की जरूरत है, बार। यह बुरा है, क्योंकि कोड एक बार query_state_data संदेश को संभालता है, टाइमआउट अब जेनरेट नहीं होता है, और पूरा सर्वर रोक देता है। (मैं मशीन पर एक खोल प्राप्त करके मैन्युअल रूप से "डिफ्रिबिलेट" कर सकता हूं और हाथ से "टाइमआउट" संदेश भेज सकता हूं, लेकिन ... eww।)

अब, मैं हमेशा उस वैकल्पिक टाइमआउट पैरामीटर को निर्दिष्ट करने के लिए याद रखने की कोशिश कर सकता हूं मेरे परिणाम मूल्य में। लेकिन यह स्केल नहीं करता है: मैं किसी दिन भूल जाऊंगा, और एक बार फिर इस बग पर घूर रहा हूं। तो: एक बेहतर तरीका क्या है?

मुझे नहीं लगता कि मैं एक वास्तविक लूप लिखना चाहता हूं जो हमेशा के लिए चलता है, और अपना अधिकांश समय सोता है; ऐसा लगता है कि ओटीपी की भावना का सामना करना पड़ता है। send_interval/2:

Answer 1

सबसे अच्छा तरीका है:

init([]) -> 
    Timer = erlang:send_after(1, self(), check), 
    {ok, Timer}. 

handle_info(check, OldTimer) -> 
    erlang:cancel_timer(OldTimer), 
    do_task(), 
    Timer = erlang:send_after(1000, self(), check), 
    {noreply, Timer}. 

Answer 2

timer मॉड्यूल :)

Answer 3

उपयोग timer का प्रयोग करें। उदाहरण के लिए:

-behavior(gen_server). 

interval_milliseconds()-> 15000. 
init()-> 
    timer:send_interval(interval_milliseconds(), interval), 
    {ok, FascinatingStateData}. 

%% this clause will be called every 15 seconds 
handle_info(interval, StateData)-> 
    State2 = do_some_work(StateData) 
    {noreply, State2}.