99 lines
2.2 KiB
Text
99 lines
2.2 KiB
Text
|
{
|
||
|
|
"cells": [
|
||
|
|
{
|
||
|
|
"cell_type": "markdown",
|
||
|
|
"metadata": {},
|
||
|
|
"source": [
|
||
|
|
"# Swactor — Getting Started\n",
|
||
|
|
"\n",
|
||
|
|
"This notebook walks through the basics of the swactor actor runtime from Python."
|
||
|
|
]
|
||
|
|
},
|
||
|
|
{
|
||
|
|
"cell_type": "code",
|
||
|
|
"execution_count": null,
|
||
|
|
"metadata": {},
|
||
|
|
"outputs": [],
|
||
|
|
"source": [
|
||
|
|
"from swactor import Runtime"
|
||
|
|
]
|
||
|
|
},
|
||
|
|
{
|
||
|
|
"cell_type": "markdown",
|
||
|
|
"metadata": {},
|
||
|
|
"source": [
|
||
|
|
"## Single-threaded: spawn, send, tick\n",
|
||
|
|
"\n",
|
||
|
|
"The simplest way to use swactor is with `tick()` — manually stepping the runtime one tick at a time."
|
||
|
|
]
|
||
|
|
},
|
||
|
|
{
|
||
|
|
"cell_type": "code",
|
||
|
|
"execution_count": null,
|
||
|
|
"metadata": {},
|
||
|
|
"outputs": [],
|
||
|
|
"source": [
|
||
|
|
"def echo(ctx, msg):\n",
|
||
|
|
" ctx.send(msg[\"reply_to\"], f\"hello, {msg['name']}!\")\n",
|
||
|
|
"\n",
|
||
|
|
"rt = Runtime()\n",
|
||
|
|
"addr = rt.spawn(echo)\n",
|
||
|
|
"inbox = rt.inbox()\n",
|
||
|
|
"\n",
|
||
|
|
"rt.send(addr, {\"name\": \"world\", \"reply_to\": inbox.addr})\n",
|
||
|
|
"rt.tick()\n",
|
||
|
|
"\n",
|
||
|
|
"print(inbox.try_recv())"
|
||
|
|
]
|
||
|
|
},
|
||
|
|
{
|
||
|
|
"cell_type": "markdown",
|
||
|
|
"metadata": {},
|
||
|
|
"source": [
|
||
|
|
"## Multi-threaded: background runtime\n",
|
||
|
|
"\n",
|
||
|
|
"For real workloads you can run the runtime on background threads with `RuntimeConfig`."
|
||
|
|
]
|
||
|
|
},
|
||
|
|
{
|
||
|
|
"cell_type": "code",
|
||
|
|
"execution_count": null,
|
||
|
|
"metadata": {},
|
||
|
|
"outputs": [],
|
||
|
|
"source": [
|
||
|
|
"import time\n",
|
||
|
|
"from swactor import Runtime, RuntimeConfig\n",
|
||
|
|
"\n",
|
||
|
|
"def echo(ctx, msg):\n",
|
||
|
|
" ctx.send(msg[\"reply_to\"], f\"hello, {msg['name']}!\")\n",
|
||
|
|
"\n",
|
||
|
|
"rt = Runtime(RuntimeConfig(num_threads=2))\n",
|
||
|
|
"addr = rt.spawn(echo)\n",
|
||
|
|
"inbox = rt.inbox()\n",
|
||
|
|
"handle = rt.run()\n",
|
||
|
|
"\n",
|
||
|
|
"for name in [\"alice\", \"bob\", \"charlie\"]:\n",
|
||
|
|
" handle.send(addr, {\"name\": name, \"reply_to\": inbox.addr})\n",
|
||
|
|
" time.sleep(0.05) # give the runtime a moment\n",
|
||
|
|
" print(inbox.try_recv())\n",
|
||
|
|
"\n",
|
||
|
|
"handle.shutdown()\n",
|
||
|
|
"handle.join()"
|
||
|
|
]
|
||
|
|
}
|
||
|
|
],
|
||
|
|
"metadata": {
|
||
|
|
"kernelspec": {
|
||
|
|
"display_name": "Python 3",
|
||
|
|
"language": "python",
|
||
|
|
"name": "python3"
|
||
|
|
},
|
||
|
|
"language_info": {
|
||
|
|
"name": "python",
|
||
|
|
"version": "3.9.0"
|
||
|
|
}
|
||
|
|
},
|
||
|
|
"nbformat": 4,
|
||
|
|
"nbformat_minor": 4
|
||
|
|
}
|