@@ -0,0 +1,33 @@
+'use strict';
+
+class Reactor {
+  #tasks = [];
+
+  enqueue(fn) {
+    this.#tasks.push(fn);
+  }
+
+  start() {
+    while (this.#tasks.length) {
+      const tasks = this.#tasks.splice(0);
+      for (const fn of tasks) fn();
+    }
+  }
+}
+
+// Usage
+
+const eventLoop = new Reactor();
+
+const fakeAsyncRead = (name) => () => {
+  const timeout = Math.random() * 1000;
+  setTimeout(() => {
+    console.log(`[Reactor] ${name} done`);
+  }, timeout);
+};
+
+eventLoop.enqueue(fakeAsyncRead('File A'));
+eventLoop.enqueue(fakeAsyncRead('File B'));
+eventLoop.enqueue(fakeAsyncRead('File C'));
+
+eventLoop.start();
@@ -0,0 +1,34 @@
+'use strict';
+
+class Proactor {
+  #tasks = [];
+
+  enqueue(fn) {
+    this.#tasks.push(fn);
+  }
+
+  async start() {
+    while (this.#tasks.length) {
+      const tasks = this.#tasks.splice(0);
+      for (const fn of tasks) await fn();
+    }
+  }
+}
+
+// Usage
+
+const eventLoop = new Proactor();
+
+const fakeAsyncRead = (name) => async () => {
+  const delay = Math.random() * 1000;
+  await new Promise((resolve) => {
+    setTimeout(resolve, delay);
+  });
+  console.log(`[Proactor] ${name} done after ${delay}ms`);
+};
+
+eventLoop.enqueue(fakeAsyncRead('File A'));
+eventLoop.enqueue(fakeAsyncRead('File B'));
+eventLoop.enqueue(fakeAsyncRead('File C'));
+
+eventLoop.start();