| Andrew Cooke | Contents | Latest | RSS | Twitter | Previous | Next

C[omp]ute

Welcome to my blog, which was once a mailing list of the same name and is still generated by mail. Please reply via the "comment" links.

Always interested in offers/projects/new ideas. Eclectic experience in fields like: numerical computing; Python web; Java enterprise; functional languages; GPGPU; SQL databases; etc. Based in Santiago, Chile; telecommute worldwide. CV; email.

Personal Projects

Lepl parser for Python.

Colorless Green.

Photography around Santiago.

SVG experiment.

Professional Portfolio

Calibration of seismometers.

Data access via web services.

Cache rewrite.

Extending OpenSSH.

C-ORM: docs, API.

Last 100 entries

Payroll Service Quotes for Cat Soft LLC; (Beating Dead Horse) StackOverflow; Current State of Justice in China; Now Is Cat Soft LLC's Chance To Save Up To 32% On Mail; Axiom of Determinacy; Ewww; Fee Chaos Book; Course on Differential Geometry; Increase Efficiency with GPS Vehicle Tracking for Cat Soft LLC; Okay, but...; Sparse Matrices, Deep Learning; Sounds Bad; Applebaum Rape; Tomato Chutney v4; Have to add...; Culturally Liberal and Nothing More; Weird Finite / Infinite Result; Your diamond is a beaten up mess; Maths Books; Good Bike Route from Providencia / Las Condes to Panul\; Iain Pears (Author of Complex Plots); Plum Jam; Excellent; More Recently; For a moment I forgot StackOverflow sucked; A Few Weeks On...; Chilean Book Recommendations; How To Write Shared Libraries; Jenny Erpenbeck (Author); Dijkstra, Coins, Tables; Python libraries error on OpenSuse; Deserving Trump; And Smugness; McCloskey Economics Trilogy; cmocka - Mocks for C; Concept Creep (Americans); Futhark - OpenCL Language; Moved / Gone; Fan and USB issues; Burgers in Santiago; The Origin of Icosahedral Symmetry in Viruses; autoenum on PyPI; Jars Explains; Tomato Chutney v3; REST; US Elections and Gender: 24 Point Swing; PPPoE on OpenSuse Leap 42.1; SuperMicro X10SDV-TLN4F/F with Opensuse Leap 42.1; Big Data AI Could Be Very Bad Indeed....; Cornering; Postcapitalism (Paul Mason); Black Science Fiction; Git is not a CDN; Mining of Massive Data Sets; Rachel Kaadzi Ghansah; How great republics meet their end; Raspberry, Strawberry and Banana Jam; Interesting Dead Areas of Math; Later Taste; For Sale; Death By Bean; It's Good!; Tomato Chutney v2; Time ATAC MX 2 Pedals - First Impressions; Online Chilean Crafts; Intellectual Variety; Taste + Texture; Time Invariance and Gauge Symmetry; Jodorowsky; Tomato Chutney; Analysis of Support for Trump; Indian SF; TP-Link TL-WR841N DNS TCP Bug; TP-Link TL-WR841N as Wireless Bridge; Sending Email On Time; Maybe run a command; Sterile Neutrinos; Strawberry and Banana Jam; The Best Of All Possible Worlds; Kenzaburo Oe: The Changeling; Peach Jam; Taste Test; Strawberry and Raspberry Jam; flac to mp3 on OpenSuse 42.1; Also, Sebald; Kenzaburo Oe Interview; Otake (Kitani Minoru) move Black 121; Is free speech in British universities under threat?; I am actually good at computers; Was This Mansplaining?; WebFaction / LetsEncrypt / General Disappointment; Sensible Philosophy of Science; George Ellis; Misplaced Intuition and Online Communities; More Reading About Japan; Visibilty / Public Comments / Domestic Violence; Ferias de Santiago; More (Clearly Deliberate); Deleted Obit Post; And then a 50 yo male posts this...; We Have Both Kinds Of Contributors

© 2006-2015 Andrew Cooke (site) / post authors (content).

Clojure macro example - dopar

From: andrew cooke <andrew@...>

Date: Sun, 10 Jun 2012 14:28:20 -0400

I just wrote my first "worthwhile" macro in Clojure (by which I mean, does
something non-trivial I expected the language to do for me).

I have some code I want to run multiple times.  The only things that changes
each time is an integer, but each run takes 10 hours.  So I had a loop that
took 10 hours per iteration.  If you know Clojure then you'll know that my
code looked like this:

  (doseq [i (range 4)]
    (do-stuff-with i))

which is basically a "for loop" that changes "i".

To save time I wanted to run those things in parallel.  So I wanted something
like Python's multiprocessing - a simple way to make "do-stuff-with i" run on
multiple cores.

Solving this went through three phases:

 - Looking for an obvious existing solution.  Couldn't find one.

 - Trying to write an implementation using basic concepts from Java like
   semaphores or ThreadPoolExecutor.  This was complicated and "felt wrong".

 - Working out how to do it the "Clojure way".  Understanding that I needed
   agents, and then writing a macro to manage the agents.

At first I was confused by agents - I thought they would be something like
processes.  But really they are just values that a process can access.  So in
my code above.  So my original idea to put "do-stuff-with" in an agent was
wrong - it is the "i" that "goes inside" the agent.

So the basic way to solve this problem in Clojure is to:

 - Create an agent for each "i"

 - Use "send" to send the function "do-stuff-with" to each agent.

 - Wait for all the agents to finish.

Behind the scenes, Clojure is careful to only let a few agents run at a time
(this is what "send" takes care of).

So a solution would look something like:

  (apply await
    (for [i (range 4)]
      (let [a (agent i)]
        (send a do-stuff-with)
        a)))

which:

 - Generates an agent for each i

 - Sends the work to the agent (which is queued to run in a thread from a 
   thread pool)

 - Creates a list of agents (the result of the "for")

 - Waits for all the agents to finish.

OK, so where does the macro come into this?  Well, this code:

  (defmacro dopar [seq-expr & body]
    (assert (= 2 (count seq-expr)) "single pair of forms in sequence
    expression")
    (let [[k v] seq-expr]
      `(apply await
	 (for [k# ~v]
	   (let [a# (agent k#)]
	     (send a# (fn [~k] ~@body))
	     a#)))))

lets me write the (apply....) above as:

  (dopar [i (range 4)]
    (do-stuff-with i))

which is, I think, pretty awesome.

Andrew

Comment on this post