fix import

Author: jph00

fastcore/parallel.py

@@ -5,14 +5,19 @@
            'run_procs', 'parallel_gen']
 
 # %% ../nbs/03a_parallel.ipynb 1
-from .utils import *
+from .imports import *
+from .basics import *
+from .foundation import *
 from .meta import *
 from .xtras import *
 from functools import wraps
 
 import concurrent.futures,time
 from multiprocessing import Process,Queue,Manager,set_start_method,get_all_start_methods,get_context
 from threading import Thread
+try:
+    if sys.platform == 'darwin' and IN_NOTEBOOK: set_start_method("fork")
+except: pass
 
 # %% ../nbs/03a_parallel.ipynb 4
 def threaded(f):

nbs/03a_parallel.ipynb

@@ -11,19 +11,24 @@
   },
   {
    "cell_type": "code",
-   "execution_count": 41,
+   "execution_count": 2,
    "metadata": {},
    "outputs": [],
    "source": [
     "#|export\n",
-    "from fastcore.utils import *\n",
+    "from fastcore.imports import *\n",
+    "from fastcore.basics import *\n",
+    "from fastcore.foundation import *\n",
     "from fastcore.meta import *\n",
     "from fastcore.xtras import *\n",
     "from functools import wraps\n",
     "\n",
     "import concurrent.futures,time\n",
     "from multiprocessing import Process,Queue,Manager,set_start_method,get_all_start_methods,get_context\n",
-    "from threading import Thread"
+    "from threading import Thread\n",
+    "try:\n",
+    "    if sys.platform == 'darwin' and IN_NOTEBOOK: set_start_method(\"fork\")\n",
+    "except: pass"
    ]
   },
   {
@@ -210,7 +215,7 @@
        "Same as Python's ThreadPoolExecutor, except can pass `max_workers==0` for serial execution"
       ],
       "text/plain": [
-       "<nbdev.showdoc.BasicMarkdownRenderer at 0x111d8beb0>"
+       "<nbdev.showdoc.BasicMarkdownRenderer at 0x1034390a0>"
       ]
      },
      "execution_count": 11,
@@ -224,7 +229,7 @@
   },
   {
    "cell_type": "code",
-   "execution_count": 44,
+   "execution_count": 12,
    "metadata": {},
    "outputs": [],
    "source": [
@@ -254,7 +259,7 @@
   },
   {
    "cell_type": "code",
-   "execution_count": 45,
+   "execution_count": 13,
    "metadata": {},
    "outputs": [
     {
@@ -271,10 +276,10 @@
        "Same as Python's ProcessPoolExecutor, except can pass `max_workers==0` for serial execution"
       ],
       "text/plain": [
-       "<nbdev.showdoc.BasicMarkdownRenderer at 0x130453370>"
+       "<nbdev.showdoc.BasicMarkdownRenderer at 0x10f325e20>"
       ]
      },
-     "execution_count": 45,
+     "execution_count": 13,
      "metadata": {},
      "output_type": "execute_result"
     }
@@ -285,7 +290,7 @@
   },
   {
    "cell_type": "code",
-   "execution_count": 46,
+   "execution_count": 14,
    "metadata": {},
    "outputs": [],
    "source": [
@@ -296,7 +301,7 @@
   },
   {
    "cell_type": "code",
-   "execution_count": 52,
+   "execution_count": 15,
    "metadata": {},
    "outputs": [],
    "source": [
@@ -320,7 +325,7 @@
   },
   {
    "cell_type": "code",
-   "execution_count": 48,
+   "execution_count": 16,
    "metadata": {},
    "outputs": [],
    "source": [
@@ -334,7 +339,7 @@
   },
   {
    "cell_type": "code",
-   "execution_count": 50,
+   "execution_count": 17,
    "metadata": {},
    "outputs": [],
    "source": [
@@ -364,11 +369,11 @@
      "name": "stdout",
      "output_type": "stream",
      "text": [
-      "0 2022-07-26 03:53:34.945994\n",
-      "1 2022-07-26 03:53:35.197160\n",
-      "2 2022-07-26 03:53:35.449657\n",
-      "3 2022-07-26 03:53:35.700623\n",
-      "4 2022-07-26 03:53:35.952134\n"
+      "0 2022-07-26 04:12:18.858918\n",
+      "1 2022-07-26 04:12:19.110316\n",
+      "2 2022-07-26 04:12:19.362060\n",
+      "3 2022-07-26 04:12:19.612606\n",
+      "4 2022-07-26 04:12:19.863821\n"
      ]
     }
    ],
@@ -384,7 +389,7 @@
   },
   {
    "cell_type": "code",
-   "execution_count": 29,
+   "execution_count": 19,
    "metadata": {},
    "outputs": [],
    "source": [
@@ -395,7 +400,7 @@
   },
   {
    "cell_type": "code",
-   "execution_count": 30,
+   "execution_count": 20,
    "metadata": {},
    "outputs": [
     {
@@ -404,7 +409,7 @@
        "(#8) [0,2,4,6,8,10,12,14]"
       ]
      },
-     "execution_count": 30,
+     "execution_count": 20,
      "metadata": {},
      "output_type": "execute_result"
     }
@@ -467,45 +472,7 @@
    "cell_type": "code",
    "execution_count": 24,
    "metadata": {},
-   "outputs": [
-    {
-     "data": {
-      "text/html": [
-       "\n",
-       "<style>\n",
-       "    /* Turns off some styling */\n",
-       "    progress {\n",
-       "        /* gets rid of default border in Firefox and Opera. */\n",
-       "        border: none;\n",
-       "        /* Needs to be in here for Safari polyfill so background images work as expected. */\n",
-       "        background-size: auto;\n",
-       "    }\n",
-       "    progress:not([value]), progress:not([value])::-webkit-progress-bar {\n",
-       "        background: repeating-linear-gradient(45deg, #7e7e7e, #7e7e7e 10px, #5c5c5c 10px, #5c5c5c 20px);\n",
-       "    }\n",
-       "    .progress-bar-interrupted, .progress-bar-interrupted::-webkit-progress-bar {\n",
-       "        background: #F44336;\n",
-       "    }\n",
-       "</style>\n"
-      ],
-      "text/plain": [
-       "<IPython.core.display.HTML object>"
-      ]
-     },
-     "metadata": {},
-     "output_type": "display_data"
-    },
-    {
-     "data": {
-      "text/html": [],
-      "text/plain": [
-       "<IPython.core.display.HTML object>"
-      ]
-     },
-     "metadata": {},
-     "output_type": "display_data"
-    }
-   ],
+   "outputs": [],
    "source": [
     "# class _C:\n",
     "#     def __call__(self, o): return ((i+1) for i in o)\n",
@@ -610,7 +577,7 @@
   },
   {
    "cell_type": "code",
-   "execution_count": 53,
+   "execution_count": 27,
    "metadata": {},
    "outputs": [],
    "source": [