from multiprocessing import Process
import os# 子进程要执行的代码
def run_proc(name):print 'Run child process %s (%s)...' % (name, os.getpid())if __name__=='__main__':print 'Parent process %s.' % os.getpid()p = Process(target=run_proc, args=('test',))print 'Process will start.'p.start()　　　　#启动进程p.join()　　　　 #等待子进程结束后再继续往下运行，通常用于进程间的同步。一个过后执行下一个print 'Process end.'

import threading
import time
def run(n):print("task ",n )time.sleep(2)print("task done",n)
start_time = time.time()
t_objs = [] #存线程实例
for i in range(5):t = threading.Thread(target=run,args=("t-%s" %i ,))t.start()t_objs.append(t) #为了不阻塞后面线程的启动，不在这里join，先放到一个列表里
for t in t_objs: #循环线程实例列表，等待所有线程执行完毕
    t.join()
print("----------all threads has finished...")
print("cost:",time.time() - start_time)
# task  t-0
# task  t-1
# task  t-2
# task  t-3
# task  t-4
# task done t-0
# task done t-1
# task done t-2
# task done t-3
# task done t-4
# ----------all threads has finished...
# cost: 2.0021145343780518

import threading
import time
def run(n):print("task ",n )time.sleep(2)print("task done",n,threading.current_thread())#打印当前线程
start_time = time.time()
t_objs = [] #存线程实例
for i in range(5):t = threading.Thread(target=run,args=("t-%s" %i ,))t.setDaemon(True) #把当前线程设置为守护线程，主线程消失守护线程强制退出，不用等join中所有线程结束！经常用于打开文件，监听端口
    t.start()t_objs.append(t) #为了不阻塞后面线程的启动，不在这里join，先放到一个列表里
for t in t_objs: #循环线程实例列表，等待所有线程执行完毕
    t.join()
time.sleep(2)
print("----------all threads has finished...",threading.current_thread(),threading.active_count())
print("cost:",time.time() - start_time)

View Code

import threading
import time
def run(n):lock.acquire()#锁global  numnum +=1time.sleep(1)lock.release()
lock = threading.Lock()#开锁
num = 0
t_objs = [] #存线程实例
for i in range(5):t = threading.Thread(target=run,args=("t-%s" %i ,))t.start()t_objs.append(t) #为了不阻塞后面线程的启动，不在这里join，先放到一个列表里for t in t_objs: #循环线程实例列表，等待所有线程执行完毕
    t.join()print("----------all threads has finished...",threading.current_thread(),threading.active_count())print("num:",num)
# ----------all threads has finished... <_MainThread(MainThread, started 6872)> 1
# num: 5

import time
import threading
event = threading.Event()
def lighter():count = 0event.set() #先设置绿灯while True:if count >5 and count < 10: #改成红灯event.clear() #把标志位清了print("\033[41;1mred light is on....\033[0m")elif count >10:event.set() #变绿灯count = 0else:print("\033[42;1mgreen light is on....\033[0m")time.sleep(1)count +=1def car(name):while True:if event.is_set(): #代表绿灯print("[%s] running..."% name )time.sleep(1)else:print("[%s] sees red light , waiting...." %name)event.wait()print("\033[34;1m[%s] green light is on, start going...\033[0m" %name)light = threading.Thread(target=lighter,)
light.start()
car1 = threading.Thread(target=car,args=("Tesla",))
car1.start()
# [Tesla] running...
# [Tesla] running...
# green light is on....
# green light is on....
# [Tesla] running...
# green light is on....
# [Tesla] running...