简易定时器 for erlang

shijiang1130

1. -module(m).
   
2. -compile(export_all).
   
3. 
   
4. do_check(URL)->
   
5.         Method      = get,
   
6.         Request     = {URL, []},
   
7.     %Options = [{sync, false}],
   
8.         Options = [],
   
9.     {ok, {{Version, 200, ReasonPhrase}, Headers, Body}} = httpc:request(Method, Request, [], Options),
   
10.         T=calendar:now_to_local_time(erlang:now()),
    
11.     io:format("Check time: ~p ~p ~p~n",[T,Version,ReasonPhrase]).
    
12.        
    
13. start(Time) ->
    
14.         inets:start(),
    
15.         spawn(fun()->timer(Time) end).
    
16. 
    
17. cancel(Pid) -> Pid ! cancel.
    
18. 
    
19. timer(Time) ->
    
20.         receive
    
21.                 cancel ->
    
22.                         void
    
23.                 after Time ->
    
24.                         do_check("http://www.baidu.com/"),
    
25.                         timer(Time)
    
26.                 end.
    
27.                

复制代码

shijiang1130

shijiang1130

arserangel

定时连接，以确定网站是否可以连接吧？

shijiang1130

arserangel 发表于 2014-09-06 17:53
定时连接，以确定网站是否可以连接吧？

是啊，就是个这个加个supervisor，但是不管如何设置，把网断了或是手动kill子进程，就挂了。

shijiang1130

1. -module(m_sup).
   
2. -behaviour(supervisor).
   
3. -export([init/1]).
   
4. -compile(export_all).
   
5. 
   
6. start_link() ->
   
7.     supervisor:start_link({local, ?MODULE}, ?MODULE, []).
   
8.        
   
9. init(_Args)->
   
10.         {ok,{{one_for_one, 1,1},
    
11.                 [{m,{m,start_link,[3000]},
    
12.                 permanent,brutal_kill,worker,[m]}]
    
13.                 }
    
14.                 }.

复制代码

1. -module(m).
   
2. -compile(export_all).
   
3. 
   
4. do_check(URL)->
   
5.         Method      = get,
   
6.         Request     = {URL, []},
   
7.     %Options = [{sync, false}],
   
8.         Options = [],
   
9.     {ok, {{Version, 200, ReasonPhrase}, _, _}} = httpc:request(Method, Request, [], Options),
   
10.         T=calendar:now_to_local_time(erlang:now()),
    
11.     io:format("Check time: ~p ~p ~p~n",[T,Version,ReasonPhrase]).
    
12.        
    
13. start_link(Time) ->
    
14.         inets:start(),
    
15.         Pid=spawn(fun()->timer(Time) end),
    
16.         {ok,Pid}.
    
17. 
    
18. cancel(Pid) -> Pid ! cancel.
    
19. 
    
20. 
    
21. timer(Time) ->
    
22.         receive
    
23.                 cancel ->
    
24.                         void
    
25.                 after Time ->
    
26.                         do_check("http://www.baidu.com/"),
    
27.                         %io:format("~p~n",["ssssssssss"]),
    
28.                         timer(Time)
    
29.                 end.
    
30.                

复制代码

shijiang1130

shijiang1130

1. 问题得以解决。是我没有处理好error

复制代码

1. run(Time) ->
   
2.         receive
   
3.                 cancel ->
   
4.                         void
   
5.                 after Time ->
   
6.                         try        do_check("http://www.baidu.com/")
   
7.                         catch
   
8.                                 _:_ -> io:format("Error detected~n")
   
9.                         end,
   
10.                         run(Time)
    
11.         end.

复制代码

arserangel

就好，解决就好。