X-Git-Url: https://git.xandkar.net/?a=blobdiff_plain;f=001%2Fsrc%2Flife_time.erl;h=204b67f5b17ba7122ef32c3a1dbe77de159927e7;hb=50c6ac0870c649f7c717639fef98eefcfc83f98c;hp=b83204342c35c29051e0cd6b85933f23f4323711;hpb=982ec72043e6de6b6b22e49acb3fe13f1f54bc93;p=cellular-automata.git diff --git a/001/src/life_time.erl b/001/src/life_time.erl index b832043..204b67f 100644 --- a/001/src/life_time.erl +++ b/001/src/life_time.erl @@ -3,8 +3,8 @@ %% API --export([start_link/2 - ,tock/2 +-export([start_link/3 + ,report_state/3 ]). %% Callbacks @@ -17,19 +17,23 @@ ]). --define(INTERVAL, 0). % In milliseconds +-define(GEN_INTERVAL, 100). % In milliseconds --define(CHAR_DEAD, 32). % Space --define(CHAR_ALIVE, 111). % o --define(CHAR_BAR, 61). % = +-define(CHAR_DEAD, 32). % " " +-define(CHAR_ALIVE, 111). % "o" +-define(CHAR_BAR, 45). % "-" -record(state, {x :: integer() + ,y :: integer() ,cells :: list(atom()) ,num_cells :: integer() + ,num_dead :: integer() + ,num_alive :: integer() ,state_pairs :: list(tuple(integer(), integer())) | [] ,replies_pending :: integer() - ,gen_count = 0 :: integer() + ,gen_id :: integer() + ,gen_began :: erlang:timestamp() }). @@ -37,81 +41,110 @@ %% API %% ============================================================================ -start_link(X, Cells) -> +start_link(X, Y, Cells) -> ServerName = {local, ?MODULE}, - Args = [X, Cells], + Args = [X, Y, Cells], Opts = [], gen_server:start_link(ServerName, ?MODULE, Args, Opts). -tock(CellID, CellState) -> - gen_server:cast(?MODULE, {tock, {CellID, CellState}}). +report_state(CellID, GenID, CellState) -> + gen_server:cast(?MODULE, {report_state, {CellID, GenID, CellState}}). %% ============================================================================ -%% Callbacks +%% Callbacks (unused) %% ============================================================================ -init([X, Cells]) -> - State = #state{x=X - ,cells=Cells - ,num_cells=length(Cells) - ,state_pairs=[] - ,replies_pending=0 - }, - schedule_next_tick(), - {ok, State}. +handle_call(_Msg, _From, State) -> {reply, ok, State}. +code_change(_Old, State, _Other) -> {ok, State}. +terminate(_Reason, State) -> {ok, State}. -terminate(_Reason, State) -> - {ok, State}. - +%% ============================================================================ +%% Callbacks +%% ============================================================================ -code_change(_Old, State, _Other) -> +init([X, Y, Cells]) -> + State = #state{x = X + ,y = Y + ,cells = Cells + ,num_cells = length(Cells) + ,state_pairs = [] + ,replies_pending = 0 + ,gen_id = 0 + }, + NextGenDelay = 0, + ok = schedule_next_gen(NextGenDelay), {ok, State}. -handle_call(_Msg, _From, State) -> - {reply, ok, State}. - - -handle_cast(next_tick, +handle_info(next_gen, #state{cells=Cells ,num_cells=NumCells ,state_pairs=[] + ,gen_id=GenID }=State) -> - ok = cast_all(Cells, tick), - {noreply, State#state{replies_pending=NumCells}}; + GenBegan = os:timestamp(), + NewGenID = GenID + 1, + ok = life_lib:cast_one2all(Cells, {next_gen, NewGenID}), + NewState = State#state{replies_pending=NumCells + ,gen_id=NewGenID + ,gen_began=GenBegan + ,num_dead=0 + ,num_alive=0 + }, + {noreply, NewState}; + +handle_info(_Msg, State) -> + {noreply, State}. -handle_cast({tock, {ID, CellState}}, + +handle_cast({report_state, {CellID, GenID, CellState}}, #state{x=X + ,y=Y + ,num_dead=NDead + ,num_alive=NAlive ,state_pairs=StatePairs ,replies_pending=RepliesPending - ,gen_count=GenCount + ,gen_id=GenID + ,gen_began=GenBegan ,num_cells=NumCells }=State) -> - NewStatePairs = [{ID, CellState} | StatePairs], + NewStatePairs = [{CellID, CellState} | StatePairs], NewRepliesPending = RepliesPending - 1, - NewState = State#state{replies_pending=NewRepliesPending}, + {NewNDead, NewNAlive} = increment_dead_or_alive(CellState, NDead, NAlive), + NewState = State#state{replies_pending=NewRepliesPending + ,num_dead=NewNDead + ,num_alive=NewNAlive + }, case NewRepliesPending of 0 -> - NewGenCount = GenCount + 1, - SortedStatePairs = lists:sort(NewStatePairs), + SortedStatePairs = lists:sort( + fun({A, _}, {B, _}) -> A < B end, + NewStatePairs + ), StateChars = [state_to_char(S) || {_, S} <- SortedStatePairs], - ok = do_print_bar(X), + + GenDurationMic = timer:now_diff(os:timestamp(), GenBegan), + GenDurationMil = GenDurationMic / 1000, + GenDurationSec = GenDurationMic / 1000000, + NextGenDelay = round(?GEN_INTERVAL - GenDurationMil), + + ok = life_observer:log_generation(GenID, GenDurationSec, NewNDead, NewNAlive), + ok = io:format( - "CELLS: ~b GENERATIONS: ~b~n", - [NumCells, NewGenCount] + "X: ~b Y: ~b CELLS: ~b DEAD: ~b ALIVE: ~b GENERATION: ~b DURATION: ~f~n", + [X, Y, NumCells, NewNDead, NewNAlive, GenID, GenDurationSec] ), ok = do_print_bar(X), ok = do_print_state_chars(X, StateChars), - ok = do_print_bar(X), - ok = timer:sleep(?INTERVAL), - schedule_next_tick(), - {noreply, NewState#state{state_pairs=[], gen_count=NewGenCount}}; + + ok = schedule_next_gen(NextGenDelay), + {noreply, NewState#state{state_pairs=[]}}; _N -> {noreply, NewState#state{state_pairs=NewStatePairs}} @@ -121,22 +154,21 @@ handle_cast(_Msg, State) -> {noreply, State}. -handle_info(_Msg, State) -> - {noreply, State}. - - %% ============================================================================ %% Internal %% ============================================================================ -schedule_next_tick() -> - gen_server:cast(?MODULE, next_tick). +increment_dead_or_alive(0, NDead, NAlive) -> {NDead + 1, NAlive}; +increment_dead_or_alive(1, NDead, NAlive) -> {NDead, NAlive + 1}. + +schedule_next_gen(Delay) when Delay > 0 -> + erlang:send_after(Delay, self(), next_gen), + ok; -cast_all([], _) -> ok; -cast_all([Server | Servers], Msg) -> - ok = gen_server:cast(Server, Msg), - cast_all(Servers, Msg). +schedule_next_gen(_) -> + erlang:send(self(), next_gen), + ok. state_to_char(0) -> ?CHAR_DEAD;