move neuron processor function into scope as code = list of stages

This commit is contained in:
Helmut Merz 2026-04-20 18:28:28 +02:00
parent 0e64a6f2c5
commit 60912e0655
2 changed files with 14 additions and 10 deletions

View file

@ -1,8 +1,8 @@
defmodule Scopes.CSys do defmodule Scopes.CSys do
alias Scopes.Core.Actor alias Scopes.Core.Actor
def neuron(proc, scope) do def neuron(scope) do
fn msg -> proc.(msg, scope) end Actor.create(fn msg -> process(msg, scope) end)
end end
def synapse(rcvr, op) do def synapse(rcvr, op) do
@ -11,21 +11,25 @@ defmodule Scopes.CSys do
# predefined neuron processors # predefined neuron processors
def echo(msg, {_state, _syns, env}) do def process(msg, scope) do
hd(elem(scope, 1)).(msg, scope)
end
def echo(msg, {_state, _code, _syns, env}) do
send(env, msg) send(env, msg)
end end
def forward(msg, {_state, syns, _env}) do def forward(msg, {_state, _code, syns, _env}) do
for s <- syns, do: s.(msg) Enum.reduce(syns, false, fn s, _acc -> s.(msg); true end)
end end
def std_proc({:parent}, {_state, _syns, env}) do def std_proc({:parent}, {_state, _code, _syns, env}) do
syn = synapse(self(), &Function.identity/1) syn = synapse(self(), &Function.identity/1)
new = Actor.create(neuron(&std_proc/2, {nil, [syn], env})) new = neuron({[], [&std_proc/2], [syn], env})
send(env, {:created, new}) send(env, {:created, new})
end end
def std_proc(msg, scope) do def std_proc(msg, scope) do
if forward(msg, scope) === [], do: echo(msg, scope) unless forward(msg, scope), do: echo(msg, scope)
end end
end end

View file

@ -7,14 +7,14 @@ defmodule Scopes.CSysTest do
describe "basic:" do describe "basic:" do
test "minimal-neural-net" do test "minimal-neural-net" do
zero = Actor.create(CSys.neuron(&CSys.std_proc/2, {nil, [], self()})) zero = CSys.neuron({[], [&CSys.std_proc/2], [], self()})
Actor.send(zero, "Hello Zero!") Actor.send(zero, "Hello Zero!")
assert_receive "Hello Zero!" assert_receive "Hello Zero!"
Actor.send(zero, {:parent}) Actor.send(zero, {:parent})
assert_receive {:created, new} assert_receive {:created, new}
Actor.send(new, "Hello New!") Actor.send(new, "Hello New!")
assert_receive "Hello New!" assert_receive "Hello New!"
#assert_receive "Hello New!" # assert_receive "Hello New!"
Process.sleep(50) Process.sleep(50)
# Actor.stop(zero) # Actor.stop(zero)
refute_received msg, "unhandled message(s): #{inspect(msg)}" refute_received msg, "unhandled message(s): #{inspect(msg)}"