import threading

def func(s):
print(s)

if __name__ == '__main__':
# 創(chuàng)建線程
thread = threading.Thread(target=func, args=('hello',))
# 啟動(dòng)線程
thread.start()
# 等待線程結(jié)束
thread.join()

import threading

def func(s):
print(s)

if __name__ == '__main__':
thread = [
threading.Thread(target=func, args=('1', ))
threading.Thread(target=func, args=('2', ))
]

[t.start() for t in thread]
[t.join() for t in thread]

import time
import threading

# 創(chuàng)建鎖
lock = threading.Lock()
# 全局變量
global_resource = [None] * 5

def change_resource(para, sleep):
# 請(qǐng)求鎖
lock.acquire()
# 這段代碼如果不加鎖，第一個(gè)線程運(yùn)行結(jié)束后global_resource中是亂的，輸出為：結(jié)果是： ['hello', 'hi', 'hi', 'hello', 'hello']
# 第二個(gè)線程運(yùn)行結(jié)束后，global_resource中還是亂的，輸出為：結(jié)果是： ['hello', 'hi', 'hi', 'hi', 'hi']
global global_resource
for i in range(len(global_resource)):
global_resource[i] = para
time.sleep(sleep)
print("結(jié)果是：", global_resource)

# 釋放鎖
lock.release()

if __name__ == '__main__':
thread = [
threading.Thread(target=change_resource, args=('hi', 2))
threading.Thread(target=change_resource, args=('hello', 1))
]

[t.start() for t in thread]
[t.join() for t in thread]

# 結(jié)果是： ['hi', 'hi', 'hi', 'hi', 'hi']
# 結(jié)果是： ['hello', 'hello', 'hello', 'hello', 'hello']

import time
import threading

# 使用成一個(gè)遞歸鎖就可以解決當(dāng)前這種死鎖情況
rlock_hi = rlock_hello = threading.RLock()

def test_thread_hi():
# 初始時(shí)鎖內(nèi)部的遞歸等級(jí)為1
rlock_hi.acquire()
print('線程test_thread_hi獲得了鎖rlock_hi')
time.sleep(2)
# 如果再次獲取同樣一把鎖，則不會(huì)阻塞，只是內(nèi)部的遞歸等級(jí)加1
rlock_hello.acquire()
print('線程test_thread_hi獲得了鎖rlock_hello')
# 釋放一次鎖，內(nèi)部遞歸等級(jí)減1
rlock_hello.release()
# 這里再次減，當(dāng)遞歸等級(jí)為0時(shí)，其他線程才可獲取到此鎖
rlock_hi.release()

def test_thread_hello():
rlock_hello.acquire()
print('線程test_thread_hello獲得了鎖rlock_hello')
time.sleep(2)
rlock_hi.acquire()
print('線程test_thread_hello獲得了鎖rlock_hi')
rlock_hi.release()
rlock_hello.release()

if __name__ == '__main__':
thread = [
threading.Thread(target=test_thread_hi)
threading.Thread(target=test_thread_hello)
]

[t.start() for t in thread]
[t.join() for t in thread]

import time
import threading

# 創(chuàng)建信號(hào)量對(duì)象，初始化計(jì)數(shù)器值為3
semaphore3 = threading.Semaphore(3)


def thread_semaphore(index):
# 信號(hào)量計(jì)數(shù)器減1
semaphore3.acquire()
time.sleep(2)
print('thread_%s is running...' % index)
# 信號(hào)量計(jì)數(shù)器加1
semaphore3.release()


if __name__ == '__main__':
# 雖然會(huì)有9個(gè)線程運(yùn)行，但是通過(guò)信號(hào)量控制同時(shí)只能有3個(gè)線程運(yùn)行
# 第4個(gè)線程啟動(dòng)時(shí)，調(diào)用acquire發(fā)現(xiàn)計(jì)數(shù)器為0了，所以就會(huì)阻塞等待計(jì)數(shù)器大于0的時(shí)候
for index in range(9):
threading.Thread(target=thread_semaphore, args=(index, )).start()