Compare commits
No commits in common. "064d737ac0826eeee8273aa279514b90ca902193" and "8fe2c25a87f03a57189cb5aaedf11947240295fa" have entirely different histories.
064d737ac0
...
8fe2c25a87
5 changed files with 2 additions and 145 deletions
11
.dev-log
11
.dev-log
|
@ -1,11 +0,0 @@
|
||||||
2024/1/1
|
|
||||||
- fixed message matching bug in naive-scalar-net/make-prop-net
|
|
||||||
|
|
||||||
2023/12/29
|
|
||||||
- jumping into project after a couple days
|
|
||||||
- fixed bug in let binding of prop-net
|
|
||||||
- TODO:
|
|
||||||
- check that adding a neighbor always adds to alert-all-propagators
|
|
||||||
and they are never removed
|
|
||||||
- debug message matching: match doesn't match symbol messages and
|
|
||||||
errors on keyword messages
|
|
14
.gitignore
vendored
14
.gitignore
vendored
|
@ -1,14 +0,0 @@
|
||||||
/target
|
|
||||||
/classes
|
|
||||||
/checkouts
|
|
||||||
profiles.clj
|
|
||||||
pom.xml
|
|
||||||
pom.xml.asc
|
|
||||||
*.jar
|
|
||||||
*.class
|
|
||||||
/.lein-*
|
|
||||||
/.nrepl-port
|
|
||||||
/.prepl-port
|
|
||||||
.hgignore
|
|
||||||
.hg/
|
|
||||||
**/**.**~
|
|
13
README.md
13
README.md
|
@ -1,13 +1,4 @@
|
||||||
# prop-net
|
# prop-net
|
||||||
|
|
||||||
A Clojure propagation network library that explores ideas proposed by Radul.
|
a Clojure propagation network library that explores ideas proposed by Radul.
|
||||||
[Propagation Networks: A Flexible and Expressive Substrate for Computation, Radul 2009](https://dspace.mit.edu/handle/1721.1/49525)
|
[Propagation Networks: A Flexible and Expressive Substrate for Computation, Radul 2009](https://dspace.mit.edu/handle/1721.1/49525)
|
||||||
|
|
||||||
## roadmap
|
|
||||||
Separate namespaces are used for each type of prop-net, building:
|
|
||||||
- naive-scalar-net *in-progress*: support for scalar data, no dependency tracking, naive scheduling
|
|
||||||
- scalar-dep-net *future*: will support dependency tracking on scalar data
|
|
||||||
- []-dep-net *future*: will experiment with algorithms for tracking composite dependencies
|
|
||||||
- []-net *future*: will experiment with composite dependencies and concurrency
|
|
||||||
|
|
||||||
|
|
|
@ -1,8 +0,0 @@
|
||||||
(defproject prop-net "0.1.0-SNAPSHOT"
|
|
||||||
:description "propagation network implementation in Clojure"
|
|
||||||
:url "https://sorrel.dev/structured/prop-net"
|
|
||||||
:license {:name ""
|
|
||||||
:url ""}
|
|
||||||
:dependencies [[org.clojure/clojure "1.11.1"]
|
|
||||||
[org.clojure/core.match "1.0.1"]]
|
|
||||||
:repl-options {:init-ns prop-net.core})
|
|
|
@ -1,101 +0,0 @@
|
||||||
(ns prop-net.naive-scalar-net
|
|
||||||
(:require [clojure.core.match :refer [match]]))
|
|
||||||
|
|
||||||
;; private definitions at the ns scope so that cells can access them, but
|
|
||||||
;; everything must be accessed through the prop-network closure itself
|
|
||||||
|
|
||||||
;; temporary set of props to alert on each run
|
|
||||||
(def ^:private alerted-propagators (atom #{}))
|
|
||||||
(def ^:private last-value-of-run (atom :done))
|
|
||||||
;; this might be for tracking? can't remember rn
|
|
||||||
(def ^:private propagators-ever-alerted (atom #{}))
|
|
||||||
|
|
||||||
;; cells is a map with each keyword being an identifier for the cell
|
|
||||||
;; this makes lookup easier as callers to prop-net do not need to hold
|
|
||||||
;; on to references of the cells themselves
|
|
||||||
(def ^:private cells (atom {}))
|
|
||||||
|
|
||||||
(def ^:private nothing [])
|
|
||||||
(defn- nothing? [thing] (= thing nothing))
|
|
||||||
|
|
||||||
(defn- alert-propagators [& propagators]
|
|
||||||
(run! (fn [propagator]
|
|
||||||
(if (not (fn? propagator))
|
|
||||||
(throw (ex-info "Alerting a non-procedure" #{:propagator propagator})))
|
|
||||||
(swap! propagators-ever-alerted #(conj % propagator))
|
|
||||||
(swap! alerted-propagators #(conj % propagator)))))
|
|
||||||
|
|
||||||
(defn- alert-propagator [p]
|
|
||||||
(alert-propagators p))
|
|
||||||
|
|
||||||
;; TODO check that adding a neighbor always adds propagator to this set
|
|
||||||
;; and they are never removed
|
|
||||||
(defn- alert-all-propagators []
|
|
||||||
(apply alert-propagators (vector @propagators-ever-alerted)))
|
|
||||||
|
|
||||||
|
|
||||||
(defn- make-cell []
|
|
||||||
(let [neighbors (atom #{})
|
|
||||||
content (atom nothing)
|
|
||||||
add-content* (fn [increment]
|
|
||||||
(cond (nothing? increment) 'ok
|
|
||||||
(nothing? @content) (do (reset! content increment)
|
|
||||||
(apply alert-propagators (vector @neighbors)))
|
|
||||||
:else (if (not (= @content increment))
|
|
||||||
(throw (ex-info "Inconsistency!"
|
|
||||||
{:content @content
|
|
||||||
:increment increment})))))
|
|
||||||
new-neighbor*! (fn [new-neighbor]
|
|
||||||
(if (not (contains? @neighbors new-neighbor))
|
|
||||||
(do (swap! neighbors #(conj %1 new-neighbor))
|
|
||||||
(alert-propagator new-neighbor))))
|
|
||||||
closure (fn [message]
|
|
||||||
(match [message]
|
|
||||||
['content] @content
|
|
||||||
['add-content] add-content*
|
|
||||||
['new-neighbor!] new-neighbor*!
|
|
||||||
:else (throw (ex-info "Unknown message to cell"
|
|
||||||
{:msg message}))))]
|
|
||||||
closure))
|
|
||||||
|
|
||||||
;; currently not implementing abort semantics
|
|
||||||
(defn make-prop-net
|
|
||||||
"construct a propagation-network closure using the core implementation introduced in Chapter 3"
|
|
||||||
[]
|
|
||||||
(let [content (fn [cell] (cell 'content))
|
|
||||||
add-content (fn [cell increment] ((cell 'add-content) increment))
|
|
||||||
new-neighbor! (fn [cell new-neighbor] ((cell 'new-neighbor!) new-neighbor))
|
|
||||||
|
|
||||||
clear-alerted-propagators! (fn []
|
|
||||||
(reset! alerted-propagators #{}))
|
|
||||||
initialize-scheduler (fn []
|
|
||||||
(clear-alerted-propagators!)
|
|
||||||
(reset! last-value-of-run :done)
|
|
||||||
(reset! propagators-ever-alerted #{})
|
|
||||||
:ok!)
|
|
||||||
|
|
||||||
any-propagators-alerted? (fn []
|
|
||||||
(not (empty? @alerted-propagators)))
|
|
||||||
|
|
||||||
;run-alerted (fn [] '())
|
|
||||||
;run (fn [] '())
|
|
||||||
|
|
||||||
closure (fn [message]
|
|
||||||
(match [message]
|
|
||||||
['alerted-propagators] @alerted-propagators
|
|
||||||
['last-value-of-run] @last-value-of-run
|
|
||||||
['propagators-ever-alerted] @propagators-ever-alerted
|
|
||||||
['cells] @cells
|
|
||||||
['initialize-scheduler] (initialize-scheduler)
|
|
||||||
|
|
||||||
|
|
||||||
['add-cell] (fn [key]
|
|
||||||
(if (key @cells)
|
|
||||||
(throw (ex-info "Identifier for cell already exists"
|
|
||||||
{:id key :cells @cells}))
|
|
||||||
(swap! cells conj {key (make-cell)})))
|
|
||||||
['cell] (fn [key] (key @cells))
|
|
||||||
:else (throw (ex-info "Unknown message" {:msg message}))
|
|
||||||
))]
|
|
||||||
|
|
||||||
closure))
|
|
Loading…
Reference in a new issue