HTML code for sharing source code

HTML Copy To Clipboarddone!

<div class="highlight" style="background: #f8f8f8"><pre style="line-height: 125%"><div id="lc1"><span style="color: #008000; font-weight: bold">import</span> <span style="color: #0000FF; font-weight: bold">threading</span>
</div><div id="lc2"><span style="color: #008000; font-weight: bold">import</span> <span style="color: #0000FF; font-weight: bold">time</span>
</div><div id="lc3"><span style="color: #008000; font-weight: bold">from</span> <span style="color: #0000FF; font-weight: bold">Queue</span> <span style="color: #008000; font-weight: bold">import</span> Queue, Empty
</div><div id="lc4">
</div><div id="lc5"><span style="color: #008000; font-weight: bold">def</span> <span style="color: #0000FF">make_work</span>(callback, tasks, limit):
</div><div id="lc6">    <span style="color: #BA2121; font-style: italic">&quot;&quot;&quot;</span>
</div><div id="lc7"><span style="color: #BA2121; font-style: italic">    Run up to &quot;limit&quot; threads, do tasks and yield results.</span>
</div><div id="lc8">
</div><div id="lc9"><span style="color: #BA2121; font-style: italic">    Arguments:</span>
</div><div id="lc10"><span style="color: #BA2121; font-style: italic">        callback - the function that will process single task</span>
</div><div id="lc11"><span style="color: #BA2121; font-style: italic">        tasks - the sequence or iterator or queue of tasks</span>
</div><div id="lc12"><span style="color: #BA2121; font-style: italic">        limit - the maximum number of threads</span>
</div><div id="lc13"><span style="color: #BA2121; font-style: italic">    &quot;&quot;&quot;</span>
</div><div id="lc14">
</div><div id="lc15">    <span style="color: #408080; font-style: italic"># If tasks is not a Queue convert them into Queue</span>
</div><div id="lc16">    <span style="color: #008000; font-weight: bold">if</span> <span style="color: #AA22FF; font-weight: bold">not</span> <span style="color: #008000">isinstance</span>(tasks, Queue):
</div><div id="lc17">        new_tasks <span style="color: #666666">=</span> Queue()
</div><div id="lc18">        [new_tasks<span style="color: #666666">.</span>put(x) <span style="color: #008000; font-weight: bold">for</span> x <span style="color: #AA22FF; font-weight: bold">in</span> tasks]
</div><div id="lc19">        tasks <span style="color: #666666">=</span> new_tasks
</div><div id="lc20">
</div><div id="lc21">    <span style="color: #408080; font-style: italic"># Here results of task processing will be saved</span>
</div><div id="lc22">    results <span style="color: #666666">=</span> Queue()
</div><div id="lc23">
</div><div id="lc24">    <span style="color: #008000; font-weight: bold">def</span> <span style="color: #0000FF">_worker</span>(tasks, results):
</div><div id="lc25">        <span style="color: #008000; font-weight: bold">while</span> <span style="color: #008000">True</span>:
</div><div id="lc26">            <span style="color: #008000; font-weight: bold">try</span>:
</div><div id="lc27">                results<span style="color: #666666">.</span>put(callback(tasks<span style="color: #666666">.</span>get(<span style="color: #008000">False</span>)))
</div><div id="lc28">            <span style="color: #008000; font-weight: bold">except</span> Empty:
</div><div id="lc29">                <span style="color: #008000; font-weight: bold">return</span>
</div><div id="lc30">
</div><div id="lc31">    <span style="color: #408080; font-style: italic"># Prepare and run up to &quot;limit&quot; threads</span>
</div><div id="lc32">    threads <span style="color: #666666">=</span> []
</div><div id="lc33">    <span style="color: #008000; font-weight: bold">for</span> x <span style="color: #AA22FF; font-weight: bold">in</span> <span style="color: #008000">xrange</span>(limit):
</div><div id="lc34">        thread <span style="color: #666666">=</span> threading<span style="color: #666666">.</span>Thread(target<span style="color: #666666">=</span>_worker, args<span style="color: #666666">=</span>[tasks, results])
</div><div id="lc35">        thread<span style="color: #666666">.</span>start()
</div><div id="lc36">        threads<span style="color: #666666">.</span>append(thread)
</div><div id="lc37">
</div><div id="lc38">    <span style="color: #408080; font-style: italic"># While tasks exist we can except some results in results queue</span>
</div><div id="lc39">    <span style="color: #008000; font-weight: bold">while</span> <span style="color: #AA22FF; font-weight: bold">not</span> tasks<span style="color: #666666">.</span>empty():
</div><div id="lc40">        <span style="color: #008000; font-weight: bold">yield</span> results<span style="color: #666666">.</span>get()
</div><div id="lc41">
</div><div id="lc42">    <span style="color: #408080; font-style: italic"># When tasks queue becomes empty wait for terminating of all threads</span>
</div><div id="lc43">    <span style="color: #008000; font-weight: bold">for</span> thread <span style="color: #AA22FF; font-weight: bold">in</span> threads:
</div><div id="lc44">        thread<span style="color: #666666">.</span>join()
</div><div id="lc45">
</div><div id="lc46">    <span style="color: #408080; font-style: italic"># Let&#39;s see if some results were placed into results queue</span>
</div><div id="lc47">    <span style="color: #008000; font-weight: bold">while</span> <span style="color: #AA22FF; font-weight: bold">not</span> results<span style="color: #666666">.</span>empty():
</div><div id="lc48">        <span style="color: #008000; font-weight: bold">yield</span> results<span style="color: #666666">.</span>get()
</div><div id="lc49">
</div><div id="lc50">
</div><div id="lc51"><span style="color: #008000; font-weight: bold">if</span> __name__ <span style="color: #666666">==</span> <span style="color: #BA2121">&#39;__main__&#39;</span>:
</div><div id="lc52">    tasks <span style="color: #666666">=</span> <span style="color: #008000">range</span>(<span style="color: #666666">100</span>)
</div><div id="lc53">
</div><div id="lc54">    <span style="color: #008000; font-weight: bold">def</span> <span style="color: #0000FF">worker</span>(arg):
</div><div id="lc55">        <span style="color: #008000; font-weight: bold">print</span> <span style="color: #BA2121">&#39;</span><span style="color: #BB6688; font-weight: bold">%s</span><span style="color: #BA2121">: </span><span style="color: #BB6688; font-weight: bold">%s</span><span style="color: #BA2121">&#39;</span> <span style="color: #666666">%</span> (threading<span style="color: #666666">.</span>currentThread(), arg)
</div><div id="lc56">        time<span style="color: #666666">.</span>sleep(<span style="color: #666666">0.1</span>)
</div><div id="lc57">
</div><div id="lc58">    <span style="color: #008000">list</span>(make_work(worker, tasks, <span style="color: #666666">10</span>))
</div></pre></div>
<p style="padding: 0; margin: 2em 0 1em 0; font-size: 0.8em; color: #666;"><span style="padding: 0 1em; background-color: #f5f5f5;"> Colored with <a style="color: #333" href="http://dumpz.org">dumpz.org</a></span></p>

BBCODE Copy To Clipboarddone!

[color=#008000][b]import[/b][/color] [color=#0000FF][b]threading[/b][/color]
[color=#008000][b]import[/b][/color] [color=#0000FF][b]time[/b][/color]
[color=#008000][b]from[/b][/color] [color=#0000FF][b]Queue[/b][/color] [color=#008000][b]import[/b][/color] Queue, Empty

[color=#008000][b]def[/b][/color] [color=#0000FF]make_work[/color](callback, tasks, limit):
    [color=#BA2121][i]"""
    Run up to "limit" threads, do tasks and yield results.

Arguments:
        callback - the function that will process single task
        tasks - the sequence or iterator or queue of tasks
        limit - the maximum number of threads
    """[/i][/color]

[color=#408080][i]# If tasks is not a Queue convert them into Queue[/i][/color]
    [color=#008000][b]if[/b][/color] [color=#AA22FF][b]not[/b][/color] [color=#008000]isinstance[/color](tasks, Queue):
        new_tasks [color=#666666]=[/color] Queue()
        [new_tasks[color=#666666].[/color]put(x) [color=#008000][b]for[/b][/color] x [color=#AA22FF][b]in[/b][/color] tasks]
        tasks [color=#666666]=[/color] new_tasks

[color=#408080][i]# Here results of task processing will be saved[/i][/color]
    results [color=#666666]=[/color] Queue()

[color=#008000][b]def[/b][/color] [color=#0000FF]_worker[/color](tasks, results):
        [color=#008000][b]while[/b][/color] [color=#008000]True[/color]:
            [color=#008000][b]try[/b][/color]:
                results[color=#666666].[/color]put(callback(tasks[color=#666666].[/color]get([color=#008000]False[/color])))
            [color=#008000][b]except[/b][/color] Empty:
                [color=#008000][b]return[/b][/color]

[color=#408080][i]# Prepare and run up to "limit" threads[/i][/color]
    threads [color=#666666]=[/color] []
    [color=#008000][b]for[/b][/color] x [color=#AA22FF][b]in[/b][/color] [color=#008000]xrange[/color](limit):
        thread [color=#666666]=[/color] threading[color=#666666].[/color]Thread(target[color=#666666]=[/color]_worker, args[color=#666666]=[/color][tasks, results])
        thread[color=#666666].[/color]start()
        threads[color=#666666].[/color]append(thread)

[color=#408080][i]# While tasks exist we can except some results in results queue[/i][/color]
    [color=#008000][b]while[/b][/color] [color=#AA22FF][b]not[/b][/color] tasks[color=#666666].[/color]empty():
        [color=#008000][b]yield[/b][/color] results[color=#666666].[/color]get()

[color=#408080][i]# When tasks queue becomes empty wait for terminating of all threads[/i][/color]
    [color=#008000][b]for[/b][/color] thread [color=#AA22FF][b]in[/b][/color] threads:
        thread[color=#666666].[/color]join()

[color=#408080][i]# Let's see if some results were placed into results queue[/i][/color]
    [color=#008000][b]while[/b][/color] [color=#AA22FF][b]not[/b][/color] results[color=#666666].[/color]empty():
        [color=#008000][b]yield[/b][/color] results[color=#666666].[/color]get()

[color=#008000][b]if[/b][/color] __name__ [color=#666666]==[/color] [color=#BA2121]'__main__'[/color]:
    tasks [color=#666666]=[/color] [color=#008000]range[/color]([color=#666666]100[/color])

[color=#008000][b]def[/b][/color] [color=#0000FF]worker[/color](arg):
        [color=#008000][b]print[/b][/color] [color=#BA2121]'[/color][color=#BB6688][b]%s[/b][/color][color=#BA2121]: [/color][color=#BB6688][b]%s[/b][/color][color=#BA2121]'[/color] [color=#666666]%[/color] (threading[color=#666666].[/color]currentThread(), arg)
        time[color=#666666].[/color]sleep([color=#666666]0.1[/color])

[color=#008000]list[/color](make_work(worker, tasks, [color=#666666]10[/color]))

--------------------------------------
Colored with http://dumpz.org

Light HTML Copy To Clipboarddone!

That method generates HTML with CSS classes. Hence you'll need the style sheet file

<div class="highlight"><pre><div id="lc1"><span class="kn">import</span> <span class="nn">threading</span>
</div><div id="lc2"><span class="kn">import</span> <span class="nn">time</span>
</div><div id="lc3"><span class="kn">from</span> <span class="nn">Queue</span> <span class="kn">import</span> <span class="n">Queue</span><span class="p">,</span> <span class="n">Empty</span>
</div><div id="lc4">
</div><div id="lc5"><span class="k">def</span> <span class="nf">make_work</span><span class="p">(</span><span class="n">callback</span><span class="p">,</span> <span class="n">tasks</span><span class="p">,</span> <span class="n">limit</span><span class="p">):</span>
</div><div id="lc6">    <span class="sd">&quot;&quot;&quot;</span>
</div><div id="lc7"><span class="sd">    Run up to &quot;limit&quot; threads, do tasks and yield results.</span>
</div><div id="lc8">
</div><div id="lc9"><span class="sd">    Arguments:</span>
</div><div id="lc10"><span class="sd">        callback - the function that will process single task</span>
</div><div id="lc11"><span class="sd">        tasks - the sequence or iterator or queue of tasks</span>
</div><div id="lc12"><span class="sd">        limit - the maximum number of threads</span>
</div><div id="lc13"><span class="sd">    &quot;&quot;&quot;</span>
</div><div id="lc14">
</div><div id="lc15">    <span class="c"># If tasks is not a Queue convert them into Queue</span>
</div><div id="lc16">    <span class="k">if</span> <span class="ow">not</span> <span class="nb">isinstance</span><span class="p">(</span><span class="n">tasks</span><span class="p">,</span> <span class="n">Queue</span><span class="p">):</span>
</div><div id="lc17">        <span class="n">new_tasks</span> <span class="o">=</span> <span class="n">Queue</span><span class="p">()</span>
</div><div id="lc18">        <span class="p">[</span><span class="n">new_tasks</span><span class="o">.</span><span class="n">put</span><span class="p">(</span><span class="n">x</span><span class="p">)</span> <span class="k">for</span> <span class="n">x</span> <span class="ow">in</span> <span class="n">tasks</span><span class="p">]</span>
</div><div id="lc19">        <span class="n">tasks</span> <span class="o">=</span> <span class="n">new_tasks</span>
</div><div id="lc20">
</div><div id="lc21">    <span class="c"># Here results of task processing will be saved</span>
</div><div id="lc22">    <span class="n">results</span> <span class="o">=</span> <span class="n">Queue</span><span class="p">()</span>
</div><div id="lc23">
</div><div id="lc24">    <span class="k">def</span> <span class="nf">_worker</span><span class="p">(</span><span class="n">tasks</span><span class="p">,</span> <span class="n">results</span><span class="p">):</span>
</div><div id="lc25">        <span class="k">while</span> <span class="bp">True</span><span class="p">:</span>
</div><div id="lc26">            <span class="k">try</span><span class="p">:</span>
</div><div id="lc27">                <span class="n">results</span><span class="o">.</span><span class="n">put</span><span class="p">(</span><span class="n">callback</span><span class="p">(</span><span class="n">tasks</span><span class="o">.</span><span class="n">get</span><span class="p">(</span><span class="bp">False</span><span class="p">)))</span>
</div><div id="lc28">            <span class="k">except</span> <span class="n">Empty</span><span class="p">:</span>
</div><div id="lc29">                <span class="k">return</span>
</div><div id="lc30">
</div><div id="lc31">    <span class="c"># Prepare and run up to &quot;limit&quot; threads</span>
</div><div id="lc32">    <span class="n">threads</span> <span class="o">=</span> <span class="p">[]</span>
</div><div id="lc33">    <span class="k">for</span> <span class="n">x</span> <span class="ow">in</span> <span class="nb">xrange</span><span class="p">(</span><span class="n">limit</span><span class="p">):</span>
</div><div id="lc34">        <span class="n">thread</span> <span class="o">=</span> <span class="n">threading</span><span class="o">.</span><span class="n">Thread</span><span class="p">(</span><span class="n">target</span><span class="o">=</span><span class="n">_worker</span><span class="p">,</span> <span class="n">args</span><span class="o">=</span><span class="p">[</span><span class="n">tasks</span><span class="p">,</span> <span class="n">results</span><span class="p">])</span>
</div><div id="lc35">        <span class="n">thread</span><span class="o">.</span><span class="n">start</span><span class="p">()</span>
</div><div id="lc36">        <span class="n">threads</span><span class="o">.</span><span class="n">append</span><span class="p">(</span><span class="n">thread</span><span class="p">)</span>
</div><div id="lc37">
</div><div id="lc38">    <span class="c"># While tasks exist we can except some results in results queue</span>
</div><div id="lc39">    <span class="k">while</span> <span class="ow">not</span> <span class="n">tasks</span><span class="o">.</span><span class="n">empty</span><span class="p">():</span>
</div><div id="lc40">        <span class="k">yield</span> <span class="n">results</span><span class="o">.</span><span class="n">get</span><span class="p">()</span>
</div><div id="lc41">
</div><div id="lc42">    <span class="c"># When tasks queue becomes empty wait for terminating of all threads</span>
</div><div id="lc43">    <span class="k">for</span> <span class="n">thread</span> <span class="ow">in</span> <span class="n">threads</span><span class="p">:</span>
</div><div id="lc44">        <span class="n">thread</span><span class="o">.</span><span class="n">join</span><span class="p">()</span>
</div><div id="lc45">
</div><div id="lc46">    <span class="c"># Let&#39;s see if some results were placed into results queue</span>
</div><div id="lc47">    <span class="k">while</span> <span class="ow">not</span> <span class="n">results</span><span class="o">.</span><span class="n">empty</span><span class="p">():</span>
</div><div id="lc48">        <span class="k">yield</span> <span class="n">results</span><span class="o">.</span><span class="n">get</span><span class="p">()</span>
</div><div id="lc49">
</div><div id="lc50">
</div><div id="lc51"><span class="k">if</span> <span class="n">__name__</span> <span class="o">==</span> <span class="s">&#39;__main__&#39;</span><span class="p">:</span>
</div><div id="lc52">    <span class="n">tasks</span> <span class="o">=</span> <span class="nb">range</span><span class="p">(</span><span class="mi">100</span><span class="p">)</span>
</div><div id="lc53">
</div><div id="lc54">    <span class="k">def</span> <span class="nf">worker</span><span class="p">(</span><span class="n">arg</span><span class="p">):</span>
</div><div id="lc55">        <span class="k">print</span> <span class="s">&#39;</span><span class="si">%s</span><span class="s">: </span><span class="si">%s</span><span class="s">&#39;</span> <span class="o">%</span> <span class="p">(</span><span class="n">threading</span><span class="o">.</span><span class="n">currentThread</span><span class="p">(),</span> <span class="n">arg</span><span class="p">)</span>
</div><div id="lc56">        <span class="n">time</span><span class="o">.</span><span class="n">sleep</span><span class="p">(</span><span class="mf">0.1</span><span class="p">)</span>
</div><div id="lc57">
</div><div id="lc58">    <span class="nb">list</span><span class="p">(</span><span class="n">make_work</span><span class="p">(</span><span class="n">worker</span><span class="p">,</span> <span class="n">tasks</span><span class="p">,</span> <span class="mi">10</span><span class="p">))</span>
</div></pre></div>
<p style="padding: 0; margin: 2em 0 1em 0; font-size: 0.8em; color: #666;"><span style="padding: 0 1em; background-color: #f5f5f5;"> Colored with <a style="color: #333" href="http://dumpz.org">dumpz.org</a></span></p>

Habrahabr.ru HTML Copy To Clipboarddone!

Use that HTML for publications on habrahabr.ru

<blockquote><code><font color="#008000"><strong>import</strong></font>&nbsp;<font color="#0000FF"><strong>threading</strong></font>
<font color="#008000"><strong>import</strong></font>&nbsp;<font color="#0000FF"><strong>time</strong></font>
<font color="#008000"><strong>from</strong></font>&nbsp;<font color="#0000FF"><strong>Queue</strong></font>&nbsp;<font color="#008000"><strong>import</strong></font>&nbsp;Queue,&nbsp;Empty

<font color="#008000"><strong>def</strong></font>&nbsp;<font color="#0000FF">make_work</font>(callback,&nbsp;tasks,&nbsp;limit):
&nbsp;&nbsp;&nbsp;&nbsp;<font color="#BA2121"><em>&quot;&quot;&quot;
&nbsp;&nbsp;&nbsp;&nbsp;Run&nbsp;up&nbsp;to&nbsp;&quot;limit&quot;&nbsp;threads,&nbsp;do&nbsp;tasks&nbsp;and&nbsp;yield&nbsp;results.

&nbsp;&nbsp;&nbsp;&nbsp;Arguments:
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;callback&nbsp;-&nbsp;the&nbsp;function&nbsp;that&nbsp;will&nbsp;process&nbsp;single&nbsp;task
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;tasks&nbsp;-&nbsp;the&nbsp;sequence&nbsp;or&nbsp;iterator&nbsp;or&nbsp;queue&nbsp;of&nbsp;tasks
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;limit&nbsp;-&nbsp;the&nbsp;maximum&nbsp;number&nbsp;of&nbsp;threads
&nbsp;&nbsp;&nbsp;&nbsp;&quot;&quot;&quot;</em></font>

&nbsp;&nbsp;&nbsp;&nbsp;<font color="#408080"><em>#&nbsp;If&nbsp;tasks&nbsp;is&nbsp;not&nbsp;a&nbsp;Queue&nbsp;convert&nbsp;them&nbsp;into&nbsp;Queue</em></font>
&nbsp;&nbsp;&nbsp;&nbsp;<font color="#008000"><strong>if</strong></font>&nbsp;<font color="#AA22FF"><strong>not</strong></font>&nbsp;<font color="#008000">isinstance</font>(tasks,&nbsp;Queue):
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;new_tasks&nbsp;<font color="#666666">=</font>&nbsp;Queue()
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;[new_tasks<font color="#666666">.</font>put(x)&nbsp;<font color="#008000"><strong>for</strong></font>&nbsp;x&nbsp;<font color="#AA22FF"><strong>in</strong></font>&nbsp;tasks]
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;tasks&nbsp;<font color="#666666">=</font>&nbsp;new_tasks

&nbsp;&nbsp;&nbsp;&nbsp;<font color="#408080"><em>#&nbsp;Here&nbsp;results&nbsp;of&nbsp;task&nbsp;processing&nbsp;will&nbsp;be&nbsp;saved</em></font>
&nbsp;&nbsp;&nbsp;&nbsp;results&nbsp;<font color="#666666">=</font>&nbsp;Queue()

&nbsp;&nbsp;&nbsp;&nbsp;<font color="#008000"><strong>def</strong></font>&nbsp;<font color="#0000FF">_worker</font>(tasks,&nbsp;results):
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<font color="#008000"><strong>while</strong></font>&nbsp;<font color="#008000">True</font>:
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<font color="#008000"><strong>try</strong></font>:
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;results<font color="#666666">.</font>put(callback(tasks<font color="#666666">.</font>get(<font color="#008000">False</font>)))
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<font color="#008000"><strong>except</strong></font>&nbsp;Empty:
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<font color="#008000"><strong>return</strong></font>

&nbsp;&nbsp;&nbsp;&nbsp;<font color="#408080"><em>#&nbsp;Prepare&nbsp;and&nbsp;run&nbsp;up&nbsp;to&nbsp;&quot;limit&quot;&nbsp;threads</em></font>
&nbsp;&nbsp;&nbsp;&nbsp;threads&nbsp;<font color="#666666">=</font>&nbsp;[]
&nbsp;&nbsp;&nbsp;&nbsp;<font color="#008000"><strong>for</strong></font>&nbsp;x&nbsp;<font color="#AA22FF"><strong>in</strong></font>&nbsp;<font color="#008000">xrange</font>(limit):
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;thread&nbsp;<font color="#666666">=</font>&nbsp;threading<font color="#666666">.</font>Thread(target<font color="#666666">=</font>_worker,&nbsp;args<font color="#666666">=</font>[tasks,&nbsp;results])
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;thread<font color="#666666">.</font>start()
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;threads<font color="#666666">.</font>append(thread)

&nbsp;&nbsp;&nbsp;&nbsp;<font color="#408080"><em>#&nbsp;While&nbsp;tasks&nbsp;exist&nbsp;we&nbsp;can&nbsp;except&nbsp;some&nbsp;results&nbsp;in&nbsp;results&nbsp;queue</em></font>
&nbsp;&nbsp;&nbsp;&nbsp;<font color="#008000"><strong>while</strong></font>&nbsp;<font color="#AA22FF"><strong>not</strong></font>&nbsp;tasks<font color="#666666">.</font>empty():
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<font color="#008000"><strong>yield</strong></font>&nbsp;results<font color="#666666">.</font>get()

&nbsp;&nbsp;&nbsp;&nbsp;<font color="#408080"><em>#&nbsp;When&nbsp;tasks&nbsp;queue&nbsp;becomes&nbsp;empty&nbsp;wait&nbsp;for&nbsp;terminating&nbsp;of&nbsp;all&nbsp;threads</em></font>
&nbsp;&nbsp;&nbsp;&nbsp;<font color="#008000"><strong>for</strong></font>&nbsp;thread&nbsp;<font color="#AA22FF"><strong>in</strong></font>&nbsp;threads:
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;thread<font color="#666666">.</font>join()

&nbsp;&nbsp;&nbsp;&nbsp;<font color="#408080"><em>#&nbsp;Let&#39;s&nbsp;see&nbsp;if&nbsp;some&nbsp;results&nbsp;were&nbsp;placed&nbsp;into&nbsp;results&nbsp;queue</em></font>
&nbsp;&nbsp;&nbsp;&nbsp;<font color="#008000"><strong>while</strong></font>&nbsp;<font color="#AA22FF"><strong>not</strong></font>&nbsp;results<font color="#666666">.</font>empty():
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<font color="#008000"><strong>yield</strong></font>&nbsp;results<font color="#666666">.</font>get()

<font color="#008000"><strong>if</strong></font>&nbsp;__name__&nbsp;<font color="#666666">==</font>&nbsp;<font color="#BA2121">&#39;__main__&#39;</font>:
&nbsp;&nbsp;&nbsp;&nbsp;tasks&nbsp;<font color="#666666">=</font>&nbsp;<font color="#008000">range</font>(<font color="#666666">100</font>)

&nbsp;&nbsp;&nbsp;&nbsp;<font color="#008000"><strong>def</strong></font>&nbsp;<font color="#0000FF">worker</font>(arg):
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<font color="#008000"><strong>print</strong></font>&nbsp;<font color="#BA2121">&#39;</font><font color="#BB6688"><strong>%s</strong></font><font color="#BA2121">:&nbsp;</font><font color="#BB6688"><strong>%s</strong></font><font color="#BA2121">&#39;</font>&nbsp;<font color="#666666">%</font>&nbsp;(threading<font color="#666666">.</font>currentThread(),&nbsp;arg)
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;time<font color="#666666">.</font>sleep(<font color="#666666">0.1</font>)

&nbsp;&nbsp;&nbsp;&nbsp;<font color="#008000">list</font>(make_work(worker,&nbsp;tasks,&nbsp;<font color="#666666">10</font>))
</code></blockquote><p><font color="gray">Colored with <a href="http://dumpz.org">dumpz.org</a></p>