Python低级线程API
Python库中的“_thread”模块提供了一个低级接口，用于处理具有多个线程共享全局数据空间的轻量级进程。为了进行同步，在此模块中定义了简单的锁（也称为互斥锁或二进制信号量）。内置的“线程”模块提供了在此模块之上构建的更高级别的线程API。
start_new_thread()
此模块级函数用于在当前进程中打开新线程。该函数将函数对象作为参数。成功创建新线程时将调用此函数。该函数的跨度对应于线程的寿命。可以通过调用sleep()函数来阻止线程。
以下代码是使用_thread模块的线程机制的简单示例。
import _thread
import time
def run( threadName):
count = 0
for i in range(1,6):
time.sleep(5)
print ( threadName, i )
_thread.start_new_thread( run, ("child", ) )
for i in range(1,6):
print ( 'main', i )
time.sleep(5)start_new_thread()函数产生一个新线程，该线程并行调用run函数。run()函数以及程序的主线程中都有一个循环。sleep()对这两个函数的调用导致执行重叠，如下所示：-
main 1 child 1 main 2 child 2 main 3 child 3 main 4 child 4 main 5 child 5
线程间同步是通过使用Lock对象实现的。allocate_lock()函数返回锁对象。可以使用以下方法
获得()
此方法无条件地获取锁，直到另一个线程将其释放为止。一次只有一个线程可以获取锁。如果成功获取了锁，则返回值为True，否则为False。
释放()
此方法释放锁定。该锁必须是较早获得的，但不一定是由同一线程获得的。
在下面的示例中，声明了两个线程。每个都run()同时调用函数。其中一个获取锁并继续进入“同步”功能，而其他等待。
import _thread
import time
def run( threadName):
lock.acquire()
synchronized(threadName)
lock.release()
def synchronized(threadName):
print (threadName,"has acquired lock")
counter = 10
while counter:
time.sleep(1)
print ('*', end='')
counter = counter-1
print('\n{} has released lock'.format( threadName))
lock = _thread.allocate_lock()
_thread.start_new_thread( run, ("t1", ) )
_thread.start_new_thread( run, ("t2", ) )输出结果
>>> t1 has acquired lock ********** t1 has released lock t2 has acquired lock ********** t2 has released lock