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
|
||||
|
||||
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)
|
||||
|
||||
## 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
|
||||
|
||||
|
||||
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)
|
|
@ -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