X-Git-Url: https://git.xandkar.net/?a=blobdiff_plain;f=001%2Fsrc%2Flife_time.erl;h=22d3300d4d63dd5d5f645b2640860091770d0d9b;hb=90456d0857c0e6ac3f9550cc18f27ad158fa8dd8;hp=1b639a7326528f27a9a0fc806f8bf7ce8b968024;hpb=3803d7be41afd2665d4e29850bf6327173a19ddd;p=cellular-automata.git diff --git a/001/src/life_time.erl b/001/src/life_time.erl index 1b639a7..22d3300 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,7 +17,7 @@ ]). --define(INTERVAL, 0). % In milliseconds +-define(INTERVAL, 100). % In milliseconds -define(CHAR_DEAD, 32). % Space -define(CHAR_ALIVE, 111). % o @@ -25,11 +25,14 @@ -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() }). @@ -37,68 +40,81 @@ %% 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}. +handle_info(_Msg, State) -> {noreply, 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 + }, + ok = schedule_next_gen(), {ok, State}. -handle_call(_Msg, _From, State) -> - {reply, ok, State}. - - -handle_cast(next_tick, +handle_cast(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}}; + NewGenID = GenID + 1, + ok = cast_all(Cells, {next_gen, NewGenID}), + NewState = State#state{replies_pending=NumCells + ,gen_id=NewGenID + ,num_dead=0 + ,num_alive=0 + }, + {noreply, NewState}; -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 ,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( fun({A, _}, {B, _}) -> A < B end, NewStatePairs @@ -106,16 +122,14 @@ handle_cast({tock, {ID, CellState}}, StateChars = [state_to_char(S) || {_, S} <- SortedStatePairs], ok = io:format( - "CELLS: ~b GENERATIONS: ~b~n", - [NumCells, NewGenCount] + "X: ~b Y: ~b CELLS: ~b DEAD: ~b ALIVE: ~b GENERATION: ~b~n", + [X, Y, NumCells, NewNDead, NewNAlive, GenID] ), ok = do_print_bar(X), - ok = do_print_state_chars(X, StateChars), - ok = timer:sleep(?INTERVAL), - schedule_next_tick(), - {noreply, NewState#state{state_pairs=[], gen_count=NewGenCount}}; + ok = schedule_next_gen(), + {noreply, NewState#state{state_pairs=[]}}; _N -> {noreply, NewState#state{state_pairs=NewStatePairs}} @@ -125,16 +139,16 @@ 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() -> + ok = gen_server:cast(?MODULE, next_gen). cast_all([], _) -> ok;