Complete Rewrite of the Runtime System.

The runtime system has been completely rewritten. Raffiot now manages
its thread pool itself. It makes the runtime system much simpler and
robust.

The Asynchronous API is now much simpler because the "Future"
restriction has been lifted.

Author: chrilves

Makefile

@@ -25,6 +25,7 @@ docs: opt
 
 opt:
 	./scripts/opt.sh
+
 env: conda/env.yml
 	conda env remove -n raffiot -y
 	conda env create -f conda/env.yml

demos/dependency_injection.py

@@ -46,7 +46,7 @@ def get(self, path: str) -> IO[None, NotFound, str]:
         return io.defer(print, f"Opening file {url}").then(response)
 
 
-main: IO[Service, NotFound, List[str]] = io.read().flat_map(
+main: IO[Service, NotFound, List[str]] = io.read.flat_map(
     lambda service: service.get("index.html").flat_map(
         lambda x: service.get("index.md").flat_map(
             lambda y: io.defer(print, "Result = ", [x, y])

demos/raffiot_demo.py

@@ -15,7 +15,7 @@ def prog(color, name, i) -> IO[None, None, None]:
     """
     if i > 0:
         return io.defer(print, f"{color}From prog {name}: {i}{reset}").then(
-            io.yield_(), io.defer_io(prog, color, name, i - 1)
+            io.yield_, io.defer_io(prog, color, name, i - 1)
         )
     else:
         return io.pure(0)

demos/raffiot_demo.sh

@@ -11,28 +11,26 @@ bgreen = "\u001b[92m"
 byellow = "\u001b[93m"
 bcyan = "\u001b[96m"
 
+
 def prog(color, name, i) -> IO[None, None, None]:
     """
     Print in `color` every number from `i` to 1.
     """
     if i > 0:
-        return (
-          io.defer(print, f"{color}From prog {name}: {i}{reset}")
-            .then(
-              io.yield_(),
-              io.defer_io(prog, color, name, i - 1)
-            )
-          )
+        return io.defer(print, f"{color}From prog {name}: {i}{reset}").then(
+            io.yield_, io.defer_io(prog, color, name, i - 1)
+        )
     else:
         return io.pure(0)
 
-#The main IO
+
+# The main IO
 main: IO[None, None, None] = (
     io.parallel(
-        prog(bred, "A", 10000),
-        prog(bgreen, "B", 10000),
-        prog(byellow, "C", 10000),
-        prog(bcyan, "D", 10000),
+        prog(bred, "A", 100000),
+        prog(bgreen, "B", 100000),
+        prog(byellow, "C", 100000),
+        prog(bcyan, "D", 100000),
     )
     .flat_map(lambda fibers: io.wait(fibers))
     .then(io.defer(print, "finished"))

docs/404.html

@@ -97,7 +97,7 @@
 
         <nav id="sidebar" class="sidebar" aria-label="Table of contents">
             <div class="sidebar-scrollbox">
-                <ol class="chapter"><li class="chapter-item expanded "><a href="raffiot.html"><strong aria-hidden="true">1.</strong> Robust and Fast Functional IO Toolkit</a></li><li class="chapter-item expanded "><a href="first_steps.html"><strong aria-hidden="true">2.</strong> First Steps with IO</a></li><li class="chapter-item expanded "><a href="failures.html"><strong aria-hidden="true">3.</strong> Failures</a></li><li class="chapter-item expanded "><a href="context.html"><strong aria-hidden="true">4.</strong> Context</a></li><li class="chapter-item expanded "><a href="lists.html"><strong aria-hidden="true">5.</strong> Combining a list of IOs</a></li><li class="chapter-item expanded "><a href="async.html"><strong aria-hidden="true">6.</strong> Asynchronous Computing</a></li><li class="chapter-item expanded "><a href="resource.html"><strong aria-hidden="true">7.</strong> Resource Management</a></li></ol>
+                <ol class="chapter"><li class="chapter-item expanded "><a href="raffiot.html"><strong aria-hidden="true">1.</strong> Robust and Fast Functional IO Toolkit</a></li><li class="chapter-item expanded "><a href="first_steps.html"><strong aria-hidden="true">2.</strong> First Steps with IO</a></li><li class="chapter-item expanded "><a href="failures.html"><strong aria-hidden="true">3.</strong> Failures</a></li><li class="chapter-item expanded "><a href="context.html"><strong aria-hidden="true">4.</strong> Context</a></li><li class="chapter-item expanded "><a href="lists.html"><strong aria-hidden="true">5.</strong> Combining a list of IOs</a></li><li class="chapter-item expanded "><a href="async.html"><strong aria-hidden="true">6.</strong> Concurrent Programming</a></li><li class="chapter-item expanded "><a href="resource.html"><strong aria-hidden="true">7.</strong> Resource Management</a></li></ol>
             </div>
             <div id="sidebar-resize-handle" class="sidebar-resize-handle"></div>
         </nav>

docs/api/index.html

@@ -28,17 +28,30 @@ <h1 class="title">Package <code>raffiot</code></h1>
 </summary>
 <pre><code class="python">from dataclasses import dataclass
 
+from typing_extensions import final
+
 __all__ = [
-    &#34;_MatchError&#34;,
+    &#34;MatchError&#34;,
 ]
 
 
+@final
 @dataclass
-class _MatchError(Exception):
+class MatchError(Exception):
     &#34;&#34;&#34;
     Exception for pattern matching errors (used internally, should NEVER happen).
     &#34;&#34;&#34;
 
+    message: str
+
+
+@final
+@dataclass
+class RuntimeFailure(Exception):
+    &#34;&#34;&#34;
+    A failure of the Runtime system.
+    &#34;&#34;&#34;
+
     message: str</code></pre>
 </details>
 </section>
@@ -58,10 +71,6 @@ <h2 class="section-title" id="header-submodules">Sub-modules</h2>
 <dd>
 <div class="desc"><p>Data structure to represent the result of computation.</p></div>
 </dd>
-<dt><code class="name"><a title="raffiot.test" href="test.html">raffiot.test</a></code></dt>
-<dd>
-<div class="desc"></div>
-</dd>
 <dt><code class="name"><a title="raffiot.untyped" href="untyped/index.html">raffiot.untyped</a></code></dt>
 <dd>
 <div class="desc"></div>
@@ -79,8 +88,8 @@ <h2 class="section-title" id="header-submodules">Sub-modules</h2>
 <section>
 <h2 class="section-title" id="header-classes">Classes</h2>
 <dl>
-<dt id="raffiot._MatchError"><code class="flex name class">
-<span>class <span class="ident">_MatchError</span></span>
+<dt id="raffiot.MatchError"><code class="flex name class">
+<span>class <span class="ident">MatchError</span></span>
 <span>(</span><span>message: str)</span>
 </code></dt>
 <dd>
@@ -89,8 +98,9 @@ <h2 class="section-title" id="header-classes">Classes</h2>
 <summary>
 <span>Expand source code</span>
 </summary>
-<pre><code class="python">@dataclass
-class _MatchError(Exception):
+<pre><code class="python">@final
+@dataclass
+class MatchError(Exception):
     &#34;&#34;&#34;
     Exception for pattern matching errors (used internally, should NEVER happen).
     &#34;&#34;&#34;
@@ -104,7 +114,7 @@ <h3>Ancestors</h3>
 </ul>
 <h3>Class variables</h3>
 <dl>
-<dt id="raffiot._MatchError.message"><code class="name">var <span class="ident">message</span> : str</code></dt>
+<dt id="raffiot.MatchError.message"><code class="name">var <span class="ident">message</span> : str</code></dt>
 <dd>
 <div class="desc"></div>
 </dd>
@@ -124,17 +134,16 @@ <h1>Index</h1>
 <li><code><a title="raffiot.io" href="io.html">raffiot.io</a></code></li>
 <li><code><a title="raffiot.resource" href="resource.html">raffiot.resource</a></code></li>
 <li><code><a title="raffiot.result" href="result.html">raffiot.result</a></code></li>
-<li><code><a title="raffiot.test" href="test.html">raffiot.test</a></code></li>
 <li><code><a title="raffiot.untyped" href="untyped/index.html">raffiot.untyped</a></code></li>
 <li><code><a title="raffiot.val" href="val.html">raffiot.val</a></code></li>
 </ul>
 </li>
 <li><h3><a href="#header-classes">Classes</a></h3>
 <ul>
 <li>
-<h4><code><a title="raffiot._MatchError" href="#raffiot._MatchError">_MatchError</a></code></h4>
+<h4><code><a title="raffiot.MatchError" href="#raffiot.MatchError">MatchError</a></code></h4>
 <ul class="">
-<li><code><a title="raffiot._MatchError.message" href="#raffiot._MatchError.message">message</a></code></li>
+<li><code><a title="raffiot.MatchError.message" href="#raffiot.MatchError.message">message</a></code></li>
 </ul>
 </li>
 </ul>