13518219792
python 线程 暂停, 恢复, 退出
超过10年行业经验，技术领先，服务至上的经营模式，全靠网络和口碑获得客户，为自己降低成本，也就是为客户降低成本。到目前业务范围包括了：网站设计、成都做网站，成都网站推广，成都网站优化，整体网络托管，重庆小程序开发公司，微信开发，成都App制作，同时也可以让客户的网站和网络营销和我们一样获得订单和生意！
我们都知道python中可以是threading模块实现多线程, 但是模块并没有提供暂停, 恢复和停止线程的方法, 一旦线程对象调用start方法后, 只能等到对应的方法函数运行完毕. 也就是说一旦start后, 线程就属于失控状态. 不过, 我们可以自己实现这些. 一般的方法就是循环地判断一个标志位, 一旦标志位到达到预定的值, 就退出循环. 这样就能做到退出线程了. 但暂停和恢复线程就有点难了, 我一直也不清除有什么好的方法, 直到我看到threading中Event对象的wait方法的描述时.
wait([timeout])
Block until the internal flag is true. If the internal flag is true on entry, return immediately. Otherwise, block until another thread calls set() to set the flag to true, or until the optional timeout occurs.
阻塞, 直到内部的标志位为True时. 如果在内部的标志位在进入时为True时, 立即返回. 否则, 阻塞直到其他线程调用set()方法将标准位设为True, 或者到达了可选的timeout时间.
When the timeout argument is present and not None, it should be a floating point number specifying a timeout for the operation in seconds (or fractions thereof).
This method returns the internal flag on exit, so it will always return True except if a timeout is given and the operation times out.
当给定了timeout参数且不为None, 它应该是一个浮点数，以秒为单位指定操作的超时（或是分数）。
此方法在退出时返回内部标志，因此除非给定了超时且操作超时，否则它将始终返回True。
Changed in version 2.7: Previously, the method always returned None.
2.7版本以前, 这个方法总会返回None.
br
利用wait的阻塞机制, 就能够实现暂停和恢复了, 再配合循环判断标识位, 就能实现退出了, 下面是代码示例:
#!/usr/bin/env python
# coding: utf-8
import threading
import time
class Job(threading.Thread):
def __init__(self, *args, **kwargs):
super(Job, self).__init__(*args, **kwargs)
self.__flag = threading.Event() # 用于暂停线程的标识
self.__flag.set() # 设置为True
self.__running = threading.Event() # 用于停止线程的标识
self.__running.set() # 将running设置为True
def run(self):
while self.__running.isSet():
self.__flag.wait() # 为True时立即返回, 为False时阻塞直到内部的标识位为True后返回
print time.time()
time.sleep(1)
def pause(self):
self.__flag.clear() # 设置为False, 让线程阻塞
def resume(self):
self.__flag.set() # 设置为True, 让线程停止阻塞
def stop(self):
self.__flag.set() # 将线程从暂停状态恢复, 如何已经暂停的话
self.__running.clear() # 设置为False
下面是测试代码:
a = Job()
a.start()
time.sleep(3)
a.pause()
time.sleep(3)
a.resume()
time.sleep(3)
a.pause()
time.sleep(2)
a.stop()
br
测试的结果:
这完成了暂停, 恢复和停止的功能. 但是这里有一个缺点: 无论是暂停还是停止, 都不是瞬时的, 必须等待run函数内部的运行到达标志位判断时才有效. 也就是说操作会滞后一次.
但是这有时也不一定是坏事. 如果run函数中涉及了文件操作或数据库操作等, 完整地运行一次后再退出, 反而能够执行剩余的资源释放操作的代码(例如各种close). 不会出现程序的文件操作符超出上限, 数据库连接未释放等尴尬的情况.
可以考虑改用 subprocess 这个库来实现
比如
p = subprocess.Popen([‘your command’, 'params and options'])
try:
p.wait(my_timeout)
except subp.TimeoutExpired:
p.kill()
超时机制。python中调用两个函数需要给函数设置超时机制，以防止它超时，这里可以用python的signal模块，signal模块可以实现程序内部的信号处理。
函数内用 return
函数外用 exit()
说明，函数内也可用 exit() 停止后面的指令执行，但这样会使基于函数的线程出现问题，所以不建议在函数内使用 exit()，函数内如果不想执行指令了，最好用 return 进行结束函数，这样可以把控制权交给主调函数，而不是退出程序
扩展资料：
return语句是python语言中函数返回的一个值，每个函数都应该有一个返回值，其中，return返回值可以是一个数值，一个字符串，一个布尔值，一个列表，或者函数。
在Python中return函数返回值return，函数中一定要有return返回值才是完整的函数，如果用户没有定义Python函数返回值，那么得到的结果是None对象。
是为了防止url不可访问，或者响应速度太慢而造成的时间浪费。
比如，你要爬取1000个网站，如果有100个需要30s才能返回数据，你等待他们返回的话就需要3000s了，如果你设置10s超时，那么就能知道最长需要多久1000个可以爬完。
如果解决了您的问题请采纳！
如果未解决请继续追问
python通过subprocess模块调用系统命令。实际使用中，有一次是命令进入了交互模式，结果web端直接卡死了。
调用时设置一个超时时间，时间用完后自动断开。
这样就避免了系统因为调用命令而僵死的问题。
