import os    print('Process (%s) start...' % os.getpid())  # Only works on Unix/Linux/Mac:  pid = os.fork()  if pid == 0:  　　print('I am child process (%s) and my parent is %s.' % (os.getpid(), os.getppid()))  else:  　　print('I (%s) just created a child process (%s).' % (os.getpid(), pid))

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('Child process will start.')  　　p.start()  　　p.join()  　　print('Child process end.')

from multiprocessing import Pool  import os, time, random    def long_time_task(name):  　　print('Run task %s (%s)...' % (name, os.getpid()))  　　start = time.time()  　　time.sleep(random.random() * 3)  　　end = time.time()  　　print('Task %s runs %0.2f seconds.' % (name, (end - start)))    if __name__=='__main__':  　　print('Parent process %s.' % os.getpid())  　　p = Pool(4)  　　for i in range(5):  　　p.apply_async(long_time_task, args=(i,))  　　print('Waiting for all subprocesses done...')  　　p.close()  　　p.join()  　　print('All subprocesses done.')

import subprocess    print('$ nslookup www.python.org')  r = subprocess.call(['nslookup', 'www.python.org'])  print('Exit code:', r)

import time, threading    def loop():  　　print('線程 %s 在運行' % threading.current_thread().name)  　　n = 0  　　while n < 5:  　　　　n = n + 1  　　　　print('線程 %s >>> %s' % (threading.current_thread().name, n))  　　　　time.sleep(1)  　　print('線程 %s 結束.' % threading.current_thread().name)    print('線程 %s 在運行' % threading.current_thread().name)  t = threading.Thread(target=loop, name='子線程1')  t2 = threading.Thread(target=loop, name='子線程2')  t.start()  t2.start()  t.join()  t2.join()  print('線程 %s 結束.' % threading.current_thread().name)

import time, threading
  num=0  lock = threading.Lock()    def action_one():  　　global num  　　for i in range(3):  　　　　lock.acquire()  　　　　try:  　　　　　　print("線程1 %d"%num)  　　　　　　num+=1  　　　　　　time.sleep(1)  　　　　finally:  　　　　　　lock.release()    def action_two():  　　global num  　　for i in range(3):  　　　　lock.acquire()  　　　　try:  　　　　　　print("線程2 %d"%num)  　　　　　　num+=1  　　　　　　time.sleep(1)  　　　　finally:  　　　　　　lock.release()    t1 = threading.Thread(target=action_one, name='子線程1')  t2 = threading.Thread(target=action_two, name='子線程2')  t1.start()  t2.start()  t1.join()  t2.join()

from multiprocessing import Process, Queue  import os, time, random    # 寫數據進程執行的代碼:  def write(q):  　　print('Process to write: %s' % os.getpid())  　　for value in ['A', 'B', 'C']:  　　　　print('Put %s to queue...' % value)  　　　　q.put(value)  　　　　time.sleep(random.random())    # 讀數據進程執行的代碼:  def read(q):  　　print('Process to read: %s' % os.getpid())  　　while True:  　　　　value = q.get(True)  　　　　print('Get %s from queue.' % value)    if __name__=='__main__':  　　# 父進程創建Queue，並傳給各個子進程：  　　q = Queue()  　　pw = Process(target=write, args=(q,))  　　pr = Process(target=read, args=(q,))  　　# 啟動子進程pw，寫入:  　　pw.start()  　　# 啟動子進程pr，讀取:  　　pr.start()  　　# 等待pw結束:  　　pw.join()  　　# pr進程里是死循環，無法等待其結束，只能強行終止:  　　pr.terminate()

import queue
  q = queue.Queue()  try:  　　data = q.get(block=False)  except queue.Empty:  　　...  try:  　　q.put(item, block=False)  except queue.Full:  　　...  try:  　　data = q.get(timeout=5.0)  except queue.Empty:  　　...  

def producer(q):  　　...  　　try:  　　　　q.put(item, block=False)  　　except queue.Full:  　　　　log.warning('queued item %r discarded!', item)  _running = True  

def consumer(q):  　　while _running:  　　　　try:  　　　　　　item = q.get(timeout=5.0)  　　　　　　# Process item  　　　　　　...  　　　　except queue.Empty:  　　　　　　pass

task_done()

join()

put(item[, block[, timeout]])

get([block[, timeout]])

empty()

from threading import Thread, Event  import time    def countdown(n, start_evt):  　　print('countdown is starting...')  　　start_evt.set()  　　while n > 0:  　　　　print('T-minus', n)  　　　　n -= 1  　　　　time.sleep(5)    start_evt = Event() # 可通過Event 判斷線程的是否已運行  t = Thread(target=countdown, args=(10, start_evt))  t.start()    print('launching countdown...')  start_evt.wait() # 等待countdown執行    # event 對象的一個重要特點是當它被設置為真時會喚醒所有等待它的線程    print('countdown is running...')

from threading import Semaphore, Lock, RLock, Condition, Event, Thread  import time    # 信號量  sema = Semaphore(3) #限制同時能訪問資源的數量為3    def foo(tid):  　　with sema:  　　　　print('{} acquire sema'.format(tid))  　　　　time.sleep(1)  　　print('{} release sema'.format(tid))      threads = []    for i in range(5):  　　t = Thread(target=foo, args=(i,))  　　threads.append(t)  　　t.start()    for t in threads:  　　t.join()

#創建鎖  mutex = threading.Lock()  #鎖定  mutex.acquire([timeout])  #釋放  mutex.release()

import threading  import time    class MyThread(threading.Thread):  　　def run(self):  　　　　global num  　　　　time.sleep(1)    　　　　if mutex.acquire(1):  　　　　　　num = num+1  　　　　　　msg = self.name+' set num to '+str(num)  　　　　　　print msg  　　　　　　mutex.acquire()  　　　　　　mutex.release()  　　　　　　mutex.release()  
num = 0  mutex = threading.RLock()  

def test():  　　for i in range(5):  　　　　t = MyThread()  　　　　t.start()
  if __name__ == '__main__':  　　test()

import threading  import time    class Producer:  　　def run(self):  　　　　global count  　　　　while True:  　　　　　　if con.acquire():  　　　　　　　　if count > 1000:  　　　　　　　　　　con.wait()  　　　　　　　　else:  　　　　　　　　　　count += 100  　　　　　　　　　　msg = threading.current_thread().name + ' produce 100, count=' + str(count)  　　　　　　　　　　print(msg)  　　　　　　　　　　con.notify() # 通知 waiting線程池中的線程  　　　　　　　　con.release()  　　　　　　　　time.sleep(1)    count = 0  con = threading.Condition()    class Consumer:  　　def run(self):  　　　　global count  　　　　while True:  　　　　if con.acquire():  　　　　　　if count < 100:  　　　　　　　　con.wait()  　　　　　　else:  　　　　　　　　count -= 3  　　　　　　　　msg = threading.current_thread().name + ' consumer 3, count=' + str(count)  　　　　　　　　print(msg)  　　　　　　　　con.notify()  　　　　　　con.release()  　　　　　　time.sleep(3)    producer = Producer()