Python语法之线程的创建与用法

蔚落 2024-03-31 16:50 72阅读 0赞

### 线程的创建与使用 ###

在Python中有很多的多线程模块，其中 `thread`ing 模块就是比较常用的。下面就来看一下如何利用 `thread`ing 创建线程以及它的常用方法。

#### 线程的创建 -threading ####

<table> 
 <tbody> 
 <tr> 
 <th>函数名</th> 
 <th>介绍</th> 
 <th>举例</th> 
 </tr> 
 <tr> 
 <td>Thread</td> 
 <td>创建线程</td> 
 <td>Thread(target, args)</td> 
 </tr> 
 </tbody> 
</table>

Thread 的动能介绍：通过调用 threading 模块的 Thread 类来实例化一个线程对象；它有两个参数： target 与 args (与创建进程时，参数相同)。target 为创建线程时要执行的函数，而 args 为是要执行这个函数时需要传入的参数。

#### 线程对象的常用方法 ####

接下里看一下线程对象中都有哪些常用的方法：

<table> 
 <tbody> 
 <tr> 
 <th>函数名</th> 
 <th>介绍</th> 
 <th>用法</th> 
 </tr> 
 <tr> 
 <td>start</td> 
 <td>启动线程</td> 
 <td>start()</td> 
 </tr> 
 <tr> 
 <td>join</td> 
 <td>阻塞线程直到线程执行结束</td> 
 <td>join(timeout=None)</td> 
 </tr> 
 <tr> 
 <td>getName</td> 
 <td>获取线程的名字</td> 
 <td>getName()</td> 
 </tr> 
 <tr> 
 <td>setName</td> 
 <td>设置线程的名字</td> 
 <td>setName(name)</td> 
 </tr> 
 <tr> 
 <td>is_alive</td> 
 <td>判断线程是否存活</td> 
 <td>is_alive()</td> 
 </tr> 
 <tr> 
 <td>setDaemon</td> 
 <td>守护线程</td> 
 <td>setDaemon(True)</td> 
 </tr> 
 </tbody> 
</table>

*  start 函数：启动一个线程；没有任何返回值和参数。
 *  join 函数：和进程中的 join 函数一样；阻塞当前的程序，主线程的任务需要等待当前子线程的任务结束后才可以继续执行；参数为
 *  timeout：代表阻塞的超时时间。
 *  getName 函数：获取当前线程的名字。
 *  setName 函数：给当前的线程设置名字；参数为 name：是一个字符串类型
 *  is\_alive 函数：判断当前线程的状态是否存货
 *  setDaemon 函数：它是一个守护线程；如果脚本任务执行完成之后，即便进程池还没有执行完成业务也会被强行终止。子线程也是如此，如果希望主进程或者是主线程先执行完自己的业务之后，依然允许子线程继续工作而不是强行关闭它们，只需要设置 setDaemon() 为 True 就可以了。

PS：通过上面的介绍，会发现其实线程对象里面的函数几乎和进程对象中的函数非常相似，它们的使用方法和使用场景几乎是相同的。

#### 线程演示案例 ####

单线程初始案例

演示 多线程之前 先看一下下面这个案例，运行结束后看看共计耗时多久

1、定义一个列表，里面写一些内容。

2、再定义一个新列表，将上一个列表的内容随机写入到新列表中；并且删除上一个列表中随机获取到的内容。

3、这里需要使用到 r andom 内置模块

代码示例如下：

<table> 
 <tbody> 
 <tr> 
 <td> 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 </td> 
 <td> <code># coding:utf-8</code> <code>import</code> <code>time</code> <code>import</code> <code>random</code> <code>old_lists </code><code>=</code> <code>[</code><code>'罗马假日'</code><code>, </code><code>'怦然心动'</code><code>, </code><code>'时空恋旅人'</code><code>, </code><code>'天使爱美丽'</code><code>, </code><code>'天使之城'</code><code>, </code><code>'倒霉爱神'</code><code>, </code><code>'爱乐之城'</code><code>]</code> <code>new_lists </code><code>=</code> <code>[]</code> <code>def</code> <code>work():</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>if</code> <code>len</code><code>(old_lists) </code><code>=</code><code>=</code> <code>0</code><code>:&nbsp;&nbsp;&nbsp;&nbsp; </code><code># 判断 old_list 的长度，如果为0 ，则表示 该列表的内容已经被删光了</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code> <code>'\'old_list\' 列表内容已经全部删除'</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>old_choice_data </code><code>=</code> <code>random.choice(old_lists)&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; </code><code># random 模块的 choice函数可以随机获取传入的 old_list 的元素</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>old_lists.remove(old_choice_data)&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; </code><code># 当获取到这个随机元素之后，将该元素从 old_lists 中删除</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>new_choice_data </code><code>=</code> <code>'%s_new'</code> <code>%</code> <code>old_choice_data&nbsp;&nbsp;&nbsp; </code><code># 将随机获取到的随机元素通过格式化方式重新赋值，区别于之前的元素</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>new_lists.append(new_choice_data)&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; </code><code># 将格式化的新的随机元素添加至 new_lists 列表</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>time.sleep(</code><code>1</code><code>)</code> <code>if</code> <code>__name__ </code><code>=</code><code>=</code> <code>'__main__'</code><code>:</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>strat_time </code><code>=</code> <code>time.time()</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>for</code> <code>i </code><code>in</code> <code>range</code><code>(</code><code>len</code><code>(old_lists)):</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>work()</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>if</code> <code>len</code><code>(old_lists) </code><code>=</code><code>=</code><code>0</code><code>:</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>print</code><code>(</code><code>'\'old_lists\' 当前为：{}'</code><code>.</code><code>format</code><code>(</code><code>None</code><code>))</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>else</code><code>:</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>print</code><code>((</code><code>'\'old_lists\' 当前为：{}'</code><code>.</code><code>format</code><code>(old_lists)))</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>if</code> <code>not</code> <code>len</code><code>(new_lists) </code><code>=</code><code>=</code> <code>0</code><code>:</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>print</code><code>((</code><code>'\'new_lists\' 当前为：{}'</code><code>.</code><code>format</code><code>(new_lists)))</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>else</code><code>:</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>print</code><code>(</code><code>'\'new_lists\' 当前为：{}'</code><code>.</code><code>format</code><code>(</code><code>None</code><code>))</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>end_time </code><code>=</code> <code>time.time()</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>print</code><code>(</code><code>'运行结束，累计耗时：{} 秒'</code><code>.</code><code>format</code><code>(end_time </code><code>-</code> <code>strat_time))</code> </td> 
 </tr> 
 </tbody> 
</table>

从运行输出结果我们可以看到整个脚本运行共计耗时7秒，而且 new\_lists 列表内的元素都经过格式化处理后加上了 \_new ；不仅如此， 因为 random模块的choice函数 原因，new\_lists 的内容顺序与 old\_lists 也是不一样；每次运行顺序都会不一样，所以 old\_lists 的顺序是无法得到保障的。

### 线程的问题 ###

通过上面的练习，我们发现进程的使用方法几乎与进程是一模一样的。它们都可以互不干扰的执行程序，也可以使得主线程的程序不需要等待子线程的任务完成之后再去执行。只不过刚刚的演示案例中我们使用了 join() 函数进行了阻塞，这里可以吧 join() 去掉，看看执行效果。

与进程一样，线程也存在着一定的问题。

线程执行的函数，也同样是无法获取返回值的。

当多个线程同时修改文件一样会造成被修改文件的数据错乱的错误（因为都是并发去操作一个文件，特别是在处理交易场景的时候，需要尤为注意）。

来源：[https://www.weidianyuedu.com][https_www.weidianyuedu.com]

[https_www.weidianyuedu.com]: https://www.weidianyuedu.com