首頁 探索 說明
登入
cnheider
/
draugr
镜像来自 https://github.com/cnheider/draugr
關註 1
讚好 1
複刻 0
檔案 問題管理 0 Wiki
分支: master
分支列表 標籤列表
draugr
/
docs
/
github
/
html
/
generated
/
draugr.multiprocessing_utilities.pooled_queue_processor.PooledQueueProcessor.html

draugr.multiprocessing_utilities.pooled_queue_processor.PooledQueueProcessor.html 26 KB
永久連結 文件歷史 原始文件

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292 
  1. 

  2. <!DOCTYPE html>
    3. 

  3. 

  4. <html lang="en">
    5. 

  5.   <head>
    6. 

  6.     <meta charset="utf-8" />
    7. 

  7.     <meta name="viewport" content="width=device-width, initial-scale=1.0" /><meta name="generator" content="Docutils 0.17.1: http://docutils.sourceforge.net/" />
    8. 

  8. 

  9.     <title>draugr.multiprocessing_utilities.pooled_queue_processor.PooledQueueProcessor &#8212; Draugr 1.0.1 documentation</title>
    10. 

  10.     <link rel="stylesheet" type="text/css" href="../_static/pygments.css" />
    11. 

  11.     <link rel="stylesheet" type="text/css" href="../_static/alabaster.css" />
    12. 

  12.     <link rel="stylesheet" type="text/css" href="../_static/graphviz.css" />
    13. 

  13.     <script data-url_root="../" id="documentation_options" src="../_static/documentation_options.js"></script>
    14. 

  14.     <script src="../_static/jquery.js"></script>
    15. 

  15.     <script src="../_static/underscore.js"></script>
    16. 

  16.     <script src="../_static/_sphinx_javascript_frameworks_compat.js"></script>
    17. 

  17.     <script src="../_static/doctools.js"></script>
    18. 

  18.     <link rel="canonical" href="pything.github.io/draugr/generated/draugr.multiprocessing_utilities.pooled_queue_processor.PooledQueueProcessor.html" />
    19. 

  19.     <link rel="index" title="Index" href="../genindex.html" />
    20. 

  20.     <link rel="search" title="Search" href="../search.html" />
    21. 

  21.     <link rel="next" title="draugr.numpy_utilities" href="draugr.numpy_utilities.html" />
    22. 

  22.     <link rel="prev" title="draugr.multiprocessing_utilities.pooled_queue_processor.PooledQueueTask" href="draugr.multiprocessing_utilities.pooled_queue_processor.PooledQueueTask.html" />
    23. 

  23.    
    24. 

  24.   <link rel="stylesheet" href="../_static/custom.css" type="text/css" />
    25. 

  25.   
    26. 

  26.   
    27. 

  27.   <meta name="viewport" content="width=device-width, initial-scale=0.9, maximum-scale=0.9" />
    28. 

  28. 

  29.   </head><body>
    30. 

  30.   
    31. 

  31. 

  32.     <div class="document">
    33. 

  33.       <div class="documentwrapper">
    34. 

  34.         <div class="bodywrapper">
    35. 

  35.           
    36. 

  36. 

  37.           <div class="body" role="main">
    38. 

  38.             
    39. 

  39.   <section id="draugr-multiprocessing-utilities-pooled-queue-processor-pooledqueueprocessor">
    40. 

  40. <h1>draugr.multiprocessing_utilities.pooled_queue_processor.PooledQueueProcessor<a class="headerlink" href="#draugr-multiprocessing-utilities-pooled-queue-processor-pooledqueueprocessor" title="Permalink to this heading">¶</a></h1>
    41. 

  41. <dl class="py class">
    42. 

  42. <dt class="sig sig-object py" id="draugr.multiprocessing_utilities.pooled_queue_processor.PooledQueueProcessor">
    43. 

  43. <em class="property"><span class="pre">class</span><span class="w"> </span></em><span class="sig-prename descclassname"><span class="pre">draugr.multiprocessing_utilities.pooled_queue_processor.</span></span><span class="sig-name descname"><span class="pre">PooledQueueProcessor</span></span><span class="sig-paren">(</span><em class="sig-param"><span class="n"><span class="pre">func</span></span></em>, <em class="sig-param"><span class="n"><span class="pre">args</span></span><span class="p"><span class="pre">:</span></span><span class="w"> </span><span class="n"><a class="reference external" href="https://docs.python.org/3/library/typing.html#typing.Iterable" title="(in Python v3.10)"><span class="pre">Iterable</span></a></span><span class="w"> </span><span class="o"><span class="pre">=</span></span><span class="w"> </span><span class="default_value"><span class="pre">()</span></span></em>, <em class="sig-param"><span class="n"><span class="pre">kwargs</span></span><span class="o"><span class="pre">=</span></span><span class="default_value"><span class="pre">None</span></span></em>, <em class="sig-param"><span class="n"><span class="pre">max_queue_size</span></span><span class="o"><span class="pre">=</span></span><span class="default_value"><span class="pre">100</span></span></em>, <em class="sig-param"><span class="n"><span class="pre">n_proc</span></span><span class="o"><span class="pre">=</span></span><span class="default_value"><span class="pre">None</span></span></em>, <em class="sig-param"><span class="n"><span class="pre">max_tasks_per_child</span></span><span class="o"><span class="pre">=</span></span><span class="default_value"><span class="pre">None</span></span></em>, <em class="sig-param"><span class="n"><span class="pre">fill_at_construction</span></span><span class="o"><span class="pre">=</span></span><span class="default_value"><span class="pre">True</span></span></em>, <em class="sig-param"><span class="n"><span class="pre">blocking</span></span><span class="o"><span class="pre">=</span></span><span class="default_value"><span class="pre">True</span></span></em><span class="sig-paren">)</span><a class="reference internal" href="../_modules/draugr/multiprocessing_utilities/pooled_queue_processor.html#PooledQueueProcessor"><span class="viewcode-link"><span class="pre">[source]</span></span></a><a class="headerlink" href="#draugr.multiprocessing_utilities.pooled_queue_processor.PooledQueueProcessor" title="Permalink to this definition">¶</a></dt>
    44. 

  44. <dd><p>Bases: <a class="reference external" href="https://docs.python.org/3/library/functions.html#object" title="(in Python v3.10)"><code class="xref py py-class docutils literal notranslate"><span class="pre">object</span></code></a></p>
    45. 

  45. <p>This is a workaround of Pythons extremely slow interprocess communication pipes.
    46. 

  46. The ideal solution would be to use a multiprocessing.queue, but it apparently communication is band
    47. 

  47. limited.
    48. 

  48. This solution has processes complete tasks (batches) and a thread add the results to a queue.queue.</p>
    49. 

  49. <dl class="py method">
    50. 

  50. <dt class="sig sig-object py" id="draugr.multiprocessing_utilities.pooled_queue_processor.PooledQueueProcessor.__init__">
    51. 

  51. <span class="sig-name descname"><span class="pre">__init__</span></span><span class="sig-paren">(</span><em class="sig-param"><span class="n"><span class="pre">func</span></span></em>, <em class="sig-param"><span class="n"><span class="pre">args</span></span><span class="p"><span class="pre">:</span></span><span class="w"> </span><span class="n"><a class="reference external" href="https://docs.python.org/3/library/typing.html#typing.Iterable" title="(in Python v3.10)"><span class="pre">Iterable</span></a></span><span class="w"> </span><span class="o"><span class="pre">=</span></span><span class="w"> </span><span class="default_value"><span class="pre">()</span></span></em>, <em class="sig-param"><span class="n"><span class="pre">kwargs</span></span><span class="o"><span class="pre">=</span></span><span class="default_value"><span class="pre">None</span></span></em>, <em class="sig-param"><span class="n"><span class="pre">max_queue_size</span></span><span class="o"><span class="pre">=</span></span><span class="default_value"><span class="pre">100</span></span></em>, <em class="sig-param"><span class="n"><span class="pre">n_proc</span></span><span class="o"><span class="pre">=</span></span><span class="default_value"><span class="pre">None</span></span></em>, <em class="sig-param"><span class="n"><span class="pre">max_tasks_per_child</span></span><span class="o"><span class="pre">=</span></span><span class="default_value"><span class="pre">None</span></span></em>, <em class="sig-param"><span class="n"><span class="pre">fill_at_construction</span></span><span class="o"><span class="pre">=</span></span><span class="default_value"><span class="pre">True</span></span></em>, <em class="sig-param"><span class="n"><span class="pre">blocking</span></span><span class="o"><span class="pre">=</span></span><span class="default_value"><span class="pre">True</span></span></em><span class="sig-paren">)</span><a class="reference internal" href="../_modules/draugr/multiprocessing_utilities/pooled_queue_processor.html#PooledQueueProcessor.__init__"><span class="viewcode-link"><span class="pre">[source]</span></span></a><a class="headerlink" href="#draugr.multiprocessing_utilities.pooled_queue_processor.PooledQueueProcessor.__init__" title="Permalink to this definition">¶</a></dt>
    52. 

  52. <dd></dd></dl>
    53. 

  53. 

  54. <p class="rubric">Methods</p>
    55. 

  55. <table class="autosummary longtable docutils align-default">
    56. 

  56. <colgroup>
    57. 

  57. <col style="width: 10%" />
    58. 

  58. <col style="width: 90%" />
    59. 

  59. </colgroup>
    60. 

  60. <tbody>
    61. 

  61. <tr class="row-odd"><td><p><a class="reference internal" href="#draugr.multiprocessing_utilities.pooled_queue_processor.PooledQueueProcessor.__init__" title="draugr.multiprocessing_utilities.pooled_queue_processor.PooledQueueProcessor.__init__"><code class="xref py py-obj docutils literal notranslate"><span class="pre">__init__</span></code></a>(func[, args, kwargs, ...])</p></td>
    62. 

  62. <td><p></p></td>
    63. 

  63. </tr>
    64. 

  64. <tr class="row-even"><td><p><a class="reference internal" href="#draugr.multiprocessing_utilities.pooled_queue_processor.PooledQueueProcessor.close" title="draugr.multiprocessing_utilities.pooled_queue_processor.PooledQueueProcessor.close"><code class="xref py py-obj docutils literal notranslate"><span class="pre">close</span></code></a>()</p></td>
    65. 

  65. <td><p>close pool</p></td>
    66. 

  66. </tr>
    67. 

  67. <tr class="row-odd"><td><p><a class="reference internal" href="#draugr.multiprocessing_utilities.pooled_queue_processor.PooledQueueProcessor.fill" title="draugr.multiprocessing_utilities.pooled_queue_processor.PooledQueueProcessor.fill"><code class="xref py py-obj docutils literal notranslate"><span class="pre">fill</span></code></a>()</p></td>
    68. 

  68. <td><p>fill queue</p></td>
    69. 

  69. </tr>
    70. 

  70. <tr class="row-even"><td><p><a class="reference internal" href="#draugr.multiprocessing_utilities.pooled_queue_processor.PooledQueueProcessor.get" title="draugr.multiprocessing_utilities.pooled_queue_processor.PooledQueueProcessor.get"><code class="xref py py-obj docutils literal notranslate"><span class="pre">get</span></code></a>()</p></td>
    71. 

  71. <td><p><dl class="field-list simple">
    72. 

  72. <dt class="field-odd">return</dt>
    73. 

  73. <dd class="field-odd"><p></p></dd>
    74. 

  74. </dl>
    75. 

  75. </p></td>
    76. 

  76. </tr>
    77. 

  77. <tr class="row-odd"><td><p><a class="reference internal" href="#draugr.multiprocessing_utilities.pooled_queue_processor.PooledQueueProcessor.maybe_fill" title="draugr.multiprocessing_utilities.pooled_queue_processor.PooledQueueProcessor.maybe_fill"><code class="xref py py-obj docutils literal notranslate"><span class="pre">maybe_fill</span></code></a>()</p></td>
    78. 

  78. <td><p>fill queue if not full</p></td>
    79. 

  79. </tr>
    80. 

  80. <tr class="row-even"><td><p><a class="reference internal" href="#draugr.multiprocessing_utilities.pooled_queue_processor.PooledQueueProcessor.put" title="draugr.multiprocessing_utilities.pooled_queue_processor.PooledQueueProcessor.put"><code class="xref py py-obj docutils literal notranslate"><span class="pre">put</span></code></a>(res)</p></td>
    81. 

  81. <td><p><dl class="field-list simple">
    82. 

  82. <dt class="field-odd">param res</dt>
    83. 

  83. <dd class="field-odd"><p></p></dd>
    84. 

  84. </dl>
    85. 

  85. </p></td>
    86. 

  86. </tr>
    87. 

  87. <tr class="row-odd"><td><p><a class="reference internal" href="#draugr.multiprocessing_utilities.pooled_queue_processor.PooledQueueProcessor.raise_error" title="draugr.multiprocessing_utilities.pooled_queue_processor.PooledQueueProcessor.raise_error"><code class="xref py py-obj docutils literal notranslate"><span class="pre">raise_error</span></code></a>(excptn)</p></td>
    88. 

  88. <td><p><dl class="field-list simple">
    89. 

  89. <dt class="field-odd">param excptn</dt>
    90. 

  90. <dd class="field-odd"><p></p></dd>
    91. 

  91. </dl>
    92. 

  92. </p></td>
    93. 

  93. </tr>
    94. 

  94. <tr class="row-even"><td><p><a class="reference internal" href="#draugr.multiprocessing_utilities.pooled_queue_processor.PooledQueueProcessor.terminate" title="draugr.multiprocessing_utilities.pooled_queue_processor.PooledQueueProcessor.terminate"><code class="xref py py-obj docutils literal notranslate"><span class="pre">terminate</span></code></a>()</p></td>
    95. 

  95. <td><p>terminate pool</p></td>
    96. 

  96. </tr>
    97. 

  97. </tbody>
    98. 

  98. </table>
    99. 

  99. <p class="rubric">Attributes</p>
    100. 

  100. <table class="autosummary longtable docutils align-default">
    101. 

  101. <colgroup>
    102. 

  102. <col style="width: 10%" />
    103. 

  103. <col style="width: 90%" />
    104. 

  104. </colgroup>
    105. 

  105. <tbody>
    106. 

  106. <tr class="row-odd"><td><p><a class="reference internal" href="#draugr.multiprocessing_utilities.pooled_queue_processor.PooledQueueProcessor.queue_size" title="draugr.multiprocessing_utilities.pooled_queue_processor.PooledQueueProcessor.queue_size"><code class="xref py py-obj docutils literal notranslate"><span class="pre">queue_size</span></code></a></p></td>
    107. 

  107. <td><p>return: :rtype:</p></td>
    108. 

  108. </tr>
    109. 

  109. </tbody>
    110. 

  110. </table>
    111. 

  111. <dl class="py method">
    112. 

  112. <dt class="sig sig-object py" id="draugr.multiprocessing_utilities.pooled_queue_processor.PooledQueueProcessor.close">
    113. 

  113. <span class="sig-name descname"><span class="pre">close</span></span><span class="sig-paren">(</span><span class="sig-paren">)</span> <span class="sig-return"><span class="sig-return-icon">&#x2192;</span> <span class="sig-return-typehint"><a class="reference external" href="https://docs.python.org/3/library/constants.html#None" title="(in Python v3.10)"><span class="pre">None</span></a></span></span><a class="reference internal" href="../_modules/draugr/multiprocessing_utilities/pooled_queue_processor.html#PooledQueueProcessor.close"><span class="viewcode-link"><span class="pre">[source]</span></span></a><a class="headerlink" href="#draugr.multiprocessing_utilities.pooled_queue_processor.PooledQueueProcessor.close" title="Permalink to this definition">¶</a></dt>
    114. 

  114. <dd><p>close pool</p>
    115. 

  115. </dd></dl>
    116. 

  116. 

  117. <dl class="py method">
    118. 

  118. <dt class="sig sig-object py" id="draugr.multiprocessing_utilities.pooled_queue_processor.PooledQueueProcessor.fill">
    119. 

  119. <span class="sig-name descname"><span class="pre">fill</span></span><span class="sig-paren">(</span><span class="sig-paren">)</span> <span class="sig-return"><span class="sig-return-icon">&#x2192;</span> <span class="sig-return-typehint"><a class="reference external" href="https://docs.python.org/3/library/constants.html#None" title="(in Python v3.10)"><span class="pre">None</span></a></span></span><a class="reference internal" href="../_modules/draugr/multiprocessing_utilities/pooled_queue_processor.html#PooledQueueProcessor.fill"><span class="viewcode-link"><span class="pre">[source]</span></span></a><a class="headerlink" href="#draugr.multiprocessing_utilities.pooled_queue_processor.PooledQueueProcessor.fill" title="Permalink to this definition">¶</a></dt>
    120. 

  120. <dd><p>fill queue</p>
    121. 

  121. </dd></dl>
    122. 

  122. 

  123. <dl class="py method">
    124. 

  124. <dt class="sig sig-object py" id="draugr.multiprocessing_utilities.pooled_queue_processor.PooledQueueProcessor.get">
    125. 

  125. <span class="sig-name descname"><span class="pre">get</span></span><span class="sig-paren">(</span><span class="sig-paren">)</span> <span class="sig-return"><span class="sig-return-icon">&#x2192;</span> <span class="sig-return-typehint"><a class="reference external" href="https://docs.python.org/3/library/typing.html#typing.Any" title="(in Python v3.10)"><span class="pre">Any</span></a></span></span><a class="reference internal" href="../_modules/draugr/multiprocessing_utilities/pooled_queue_processor.html#PooledQueueProcessor.get"><span class="viewcode-link"><span class="pre">[source]</span></span></a><a class="headerlink" href="#draugr.multiprocessing_utilities.pooled_queue_processor.PooledQueueProcessor.get" title="Permalink to this definition">¶</a></dt>
    126. 

  126. <dd><dl class="field-list simple">
    127. 

  127. <dt class="field-odd">Returns</dt>
    128. 

  128. <dd class="field-odd"><p></p>
    129. 

  129. </dd>
    130. 

  130. </dl>
    131. 

  131. </dd></dl>
    132. 

  132. 

  133. <dl class="py method">
    134. 

  134. <dt class="sig sig-object py" id="draugr.multiprocessing_utilities.pooled_queue_processor.PooledQueueProcessor.maybe_fill">
    135. 

  135. <span class="sig-name descname"><span class="pre">maybe_fill</span></span><span class="sig-paren">(</span><span class="sig-paren">)</span> <span class="sig-return"><span class="sig-return-icon">&#x2192;</span> <span class="sig-return-typehint"><a class="reference external" href="https://docs.python.org/3/library/constants.html#None" title="(in Python v3.10)"><span class="pre">None</span></a></span></span><a class="reference internal" href="../_modules/draugr/multiprocessing_utilities/pooled_queue_processor.html#PooledQueueProcessor.maybe_fill"><span class="viewcode-link"><span class="pre">[source]</span></span></a><a class="headerlink" href="#draugr.multiprocessing_utilities.pooled_queue_processor.PooledQueueProcessor.maybe_fill" title="Permalink to this definition">¶</a></dt>
    136. 

  136. <dd><p>fill queue if not full</p>
    137. 

  137. </dd></dl>
    138. 

  138. 

  139. <dl class="py method">
    140. 

  140. <dt class="sig sig-object py" id="draugr.multiprocessing_utilities.pooled_queue_processor.PooledQueueProcessor.put">
    141. 

  141. <span class="sig-name descname"><span class="pre">put</span></span><span class="sig-paren">(</span><em class="sig-param"><span class="n"><span class="pre">res</span></span></em><span class="sig-paren">)</span> <span class="sig-return"><span class="sig-return-icon">&#x2192;</span> <span class="sig-return-typehint"><a class="reference external" href="https://docs.python.org/3/library/constants.html#None" title="(in Python v3.10)"><span class="pre">None</span></a></span></span><a class="reference internal" href="../_modules/draugr/multiprocessing_utilities/pooled_queue_processor.html#PooledQueueProcessor.put"><span class="viewcode-link"><span class="pre">[source]</span></span></a><a class="headerlink" href="#draugr.multiprocessing_utilities.pooled_queue_processor.PooledQueueProcessor.put" title="Permalink to this definition">¶</a></dt>
    142. 

  142. <dd><dl class="field-list simple">
    143. 

  143. <dt class="field-odd">Parameters</dt>
    144. 

  144. <dd class="field-odd"><p><strong>res</strong> – </p>
    145. 

  145. </dd>
    146. 

  146. </dl>
    147. 

  147. </dd></dl>
    148. 

  148. 

  149. <dl class="py property">
    150. 

  150. <dt class="sig sig-object py" id="draugr.multiprocessing_utilities.pooled_queue_processor.PooledQueueProcessor.queue_size">
    151. 

  151. <em class="property"><span class="pre">property</span><span class="w"> </span></em><span class="sig-name descname"><span class="pre">queue_size</span></span><em class="property"><span class="p"><span class="pre">:</span></span><span class="w"> </span><a class="reference external" href="https://docs.python.org/3/library/functions.html#int" title="(in Python v3.10)"><span class="pre">int</span></a></em><a class="headerlink" href="#draugr.multiprocessing_utilities.pooled_queue_processor.PooledQueueProcessor.queue_size" title="Permalink to this definition">¶</a></dt>
    152. 

  152. <dd><p>return:
    153. 

  153. :rtype:</p>
    154. 

  154. </dd></dl>
    155. 

  155. 

  156. <dl class="py method">
    157. 

  157. <dt class="sig sig-object py" id="draugr.multiprocessing_utilities.pooled_queue_processor.PooledQueueProcessor.raise_error">
    158. 

  158. <span class="sig-name descname"><span class="pre">raise_error</span></span><span class="sig-paren">(</span><em class="sig-param"><span class="n"><span class="pre">excptn</span></span></em><span class="sig-paren">)</span> <span class="sig-return"><span class="sig-return-icon">&#x2192;</span> <span class="sig-return-typehint"><a class="reference external" href="https://docs.python.org/3/library/constants.html#None" title="(in Python v3.10)"><span class="pre">None</span></a></span></span><a class="reference internal" href="../_modules/draugr/multiprocessing_utilities/pooled_queue_processor.html#PooledQueueProcessor.raise_error"><span class="viewcode-link"><span class="pre">[source]</span></span></a><a class="headerlink" href="#draugr.multiprocessing_utilities.pooled_queue_processor.PooledQueueProcessor.raise_error" title="Permalink to this definition">¶</a></dt>
    159. 

  159. <dd><dl class="field-list simple">
    160. 

  160. <dt class="field-odd">Parameters</dt>
    161. 

  161. <dd class="field-odd"><p><strong>excptn</strong> – </p>
    162. 

  162. </dd>
    163. 

  163. </dl>
    164. 

  164. </dd></dl>
    165. 

  165. 

  166. <dl class="py method">
    167. 

  167. <dt class="sig sig-object py" id="draugr.multiprocessing_utilities.pooled_queue_processor.PooledQueueProcessor.terminate">
    168. 

  168. <span class="sig-name descname"><span class="pre">terminate</span></span><span class="sig-paren">(</span><span class="sig-paren">)</span> <span class="sig-return"><span class="sig-return-icon">&#x2192;</span> <span class="sig-return-typehint"><a class="reference external" href="https://docs.python.org/3/library/constants.html#None" title="(in Python v3.10)"><span class="pre">None</span></a></span></span><a class="reference internal" href="../_modules/draugr/multiprocessing_utilities/pooled_queue_processor.html#PooledQueueProcessor.terminate"><span class="viewcode-link"><span class="pre">[source]</span></span></a><a class="headerlink" href="#draugr.multiprocessing_utilities.pooled_queue_processor.PooledQueueProcessor.terminate" title="Permalink to this definition">¶</a></dt>
    169. 

  169. <dd><p>terminate pool</p>
    170. 

  170. </dd></dl>
    171. 

  171. 

  172. </dd></dl>
    173. 

  173. 

  174. </section>
    175. 

  175. 

  176. 

  177.           </div>
    178. 

  178.           
    179. 

  179.         </div>
    180. 

  180.       </div>
    181. 

  181.       <div class="sphinxsidebar" role="navigation" aria-label="main navigation">
    182. 

  182.         <div class="sphinxsidebarwrapper">
    183. 

  183.             <p class="logo"><a href="../index.html">
    184. 

  184.               <img class="logo" src="../_static/valknut.svg" alt="Logo"/>
    185. 

  185.             </a></p>
    186. 

  186. <h1 class="logo"><a href="../index.html">Draugr</a></h1>
    187. 

  187. 

  188. 

  189. 

  190. 

  191. 

  192. 

  193. 

  194. 

  195. <h3>Navigation</h3>
    196. 

  196. <ul class="current">
    197. 

  197. <li class="toctree-l1 current"><a class="reference internal" href="draugr.html">draugr</a><ul class="current">
    198. 

  198. <li class="toctree-l2"><a class="reference internal" href="draugr.dist_is_editable.html">draugr.dist_is_editable</a></li>
    199. 

  199. <li class="toctree-l2"><a class="reference internal" href="draugr.get_version.html">draugr.get_version</a></li>
    200. 

  200. <li class="toctree-l2"><a class="reference internal" href="draugr.dlib_utilities.html">draugr.dlib_utilities</a></li>
    201. 

  201. <li class="toctree-l2"><a class="reference internal" href="draugr.drawers.html">draugr.drawers</a></li>
    202. 

  202. <li class="toctree-l2"><a class="reference internal" href="draugr.entry_points.html">draugr.entry_points</a></li>
    203. 

  203. <li class="toctree-l2"><a class="reference internal" href="draugr.extensions.html">draugr.extensions</a></li>
    204. 

  204. <li class="toctree-l2"><a class="reference internal" href="draugr.ffmpeg_utilities.html">draugr.ffmpeg_utilities</a></li>
    205. 

  205. <li class="toctree-l2"><a class="reference internal" href="draugr.jax_utilities.html">draugr.jax_utilities</a></li>
    206. 

  206. <li class="toctree-l2"><a class="reference internal" href="draugr.metrics.html">draugr.metrics</a></li>
    207. 

  207. <li class="toctree-l2 current"><a class="reference internal" href="draugr.multiprocessing_utilities.html">draugr.multiprocessing_utilities</a><ul class="current">
    208. 

  208. <li class="toctree-l3 current"><a class="reference internal" href="draugr.multiprocessing_utilities.pooled_queue_processor.html">draugr.multiprocessing_utilities.pooled_queue_processor</a><ul class="current">
    209. 

  209. <li class="toctree-l4"><a class="reference internal" href="draugr.multiprocessing_utilities.pooled_queue_processor.CloudPickleBase.html">draugr.multiprocessing_utilities.pooled_queue_processor.CloudPickleBase</a></li>
    210. 

  210. <li class="toctree-l4"><a class="reference internal" href="draugr.multiprocessing_utilities.pooled_queue_processor.PooledQueueTask.html">draugr.multiprocessing_utilities.pooled_queue_processor.PooledQueueTask</a></li>
    211. 

  211. <li class="toctree-l4 current"><a class="current reference internal" href="#">draugr.multiprocessing_utilities.pooled_queue_processor.PooledQueueProcessor</a></li>
    212. 

  212. </ul>
    213. 

  213. </li>
    214. 

  214. </ul>
    215. 

  215. </li>
    216. 

  216. <li class="toctree-l2"><a class="reference internal" href="draugr.numpy_utilities.html">draugr.numpy_utilities</a></li>
    217. 

  217. <li class="toctree-l2"><a class="reference internal" href="draugr.opencv_utilities.html">draugr.opencv_utilities</a></li>
    218. 

  218. <li class="toctree-l2"><a class="reference internal" href="draugr.os_utilities.html">draugr.os_utilities</a></li>
    219. 

  219. <li class="toctree-l2"><a class="reference internal" href="draugr.pandas_utilities.html">draugr.pandas_utilities</a></li>
    220. 

  220. <li class="toctree-l2"><a class="reference internal" href="draugr.pygame_utilities.html">draugr.pygame_utilities</a></li>
    221. 

  221. <li class="toctree-l2"><a class="reference internal" href="draugr.python_utilities.html">draugr.python_utilities</a></li>
    222. 

  222. <li class="toctree-l2"><a class="reference internal" href="draugr.random_utilities.html">draugr.random_utilities</a></li>
    223. 

  223. <li class="toctree-l2"><a class="reference internal" href="draugr.scipy_utilities.html">draugr.scipy_utilities</a></li>
    224. 

  224. <li class="toctree-l2"><a class="reference internal" href="draugr.stopping.html">draugr.stopping</a></li>
    225. 

  225. <li class="toctree-l2"><a class="reference internal" href="draugr.tensorboard_utilities.html">draugr.tensorboard_utilities</a></li>
    226. 

  226. <li class="toctree-l2"><a class="reference internal" href="draugr.threading_utilities.html">draugr.threading_utilities</a></li>
    227. 

  227. <li class="toctree-l2"><a class="reference internal" href="draugr.torch_utilities.html">draugr.torch_utilities</a></li>
    228. 

  228. <li class="toctree-l2"><a class="reference internal" href="draugr.tqdm_utilities.html">draugr.tqdm_utilities</a></li>
    229. 

  229. <li class="toctree-l2"><a class="reference internal" href="draugr.visualisation.html">draugr.visualisation</a></li>
    230. 

  230. <li class="toctree-l2"><a class="reference internal" href="draugr.writers.html">draugr.writers</a></li>
    231. 

  231. </ul>
    232. 

  232. </li>
    233. 

  233. </ul>
    234. 

  234. <p class="caption" role="heading"><span class="caption-text">Notes</span></p>
    235. 

  235. <ul>
    236. 

  236. <li class="toctree-l1"><a class="reference internal" href="../getting_started.html">Getting Started</a></li>
    237. 

  237. </ul>
    238. 

  238. 

  239. <div class="relations">
    240. 

  240. <h3>Related Topics</h3>
    241. 

  241. <ul>
    242. 

  242.   <li><a href="../index.html">Documentation overview</a><ul>
    243. 

  243.   <li><a href="draugr.html">draugr</a><ul>
    244. 

  244.   <li><a href="draugr.multiprocessing_utilities.html">draugr.multiprocessing_utilities</a><ul>
    245. 

  245.   <li><a href="draugr.multiprocessing_utilities.pooled_queue_processor.html">draugr.multiprocessing_utilities.pooled_queue_processor</a><ul>
    246. 

  246.       <li>Previous: <a href="draugr.multiprocessing_utilities.pooled_queue_processor.PooledQueueTask.html" title="previous chapter">draugr.multiprocessing_utilities.pooled_queue_processor.PooledQueueTask</a></li>
    247. 

  247.       <li>Next: <a href="draugr.numpy_utilities.html" title="next chapter">draugr.numpy_utilities</a></li>
    248. 

  248.   </ul></li>
    249. 

  249.   </ul></li>
    250. 

  250.   </ul></li>
    251. 

  251.   </ul></li>
    252. 

  252. </ul>
    253. 

  253. </div>
    254. 

  254. <div id="searchbox" style="display: none" role="search">
    255. 

  255.   <h3 id="searchlabel">Quick search</h3>
    256. 

  256.     <div class="searchformwrapper">
    257. 

  257.     <form class="search" action="../search.html" method="get">
    258. 

  258.       <input type="text" name="q" aria-labelledby="searchlabel" autocomplete="off" autocorrect="off" autocapitalize="off" spellcheck="false"/>
    259. 

  259.       <input type="submit" value="Go" />
    260. 

  260.     </form>
    261. 

  261.     </div>
    262. 

  262. </div>
    263. 

  263. <script>document.getElementById('searchbox').style.display = "block"</script>
    264. 

  264. 

  265. 

  266. 

  267. 

  268. 

  269. 

  270. 

  271. 

  272.         </div>
    273. 

  273.       </div>
    274. 

  274.       <div class="clearer"></div>
    275. 

  275.     </div>
    276. 

  276.     <div class="footer">
    277. 

  277.       &copy;.
    278. 

  278.       
    279. 

  279.       |
    280. 

  280.       Powered by <a href="http://sphinx-doc.org/">Sphinx 5.0.2</a>
    281. 

  281.       &amp; <a href="https://github.com/bitprophet/alabaster">Alabaster 0.7.12</a>
    282. 

  282.       
    283. 

  283.       |
    284. 

  284.       <a href="../_sources/generated/draugr.multiprocessing_utilities.pooled_queue_processor.PooledQueueProcessor.rst.txt"
    285. 

  285.           rel="nofollow">Page source</a>
    286. 

  286.     </div>
    287. 

  287. 

  288.     
    289. 

  289. 

  290.     
    291. 

  291.   </body>
    292. 

  292. </html>
    293.