#coding=gbk
import threading, time, random
count = 0
class Counter(threading.Thread):
  def __init__(self, lock, threadName):
    
'''@summary: 初始化對(duì)象。
     
    
@param lock: 瑣對(duì)象。
    
@param threadName: 線程名稱。
    
'''
    super(Counter, self).__init__(name = threadName) 
#注意：一定要顯式的調(diào)用父類的初始
化函數(shù)。
    self.lock = lock
   
  def run(self):
    
'''@summary: 重寫父類run方法，在線程啟動(dòng)后執(zhí)行該方法內(nèi)的代碼。
    
'''
    global count
    self.lock.acquire()
    for i in xrange(10000):
      count = count + 1
    self.lock.release()
lock = threading.Lock()
for i in range(5): 
  Counter(lock, "thread-" + str(i)).start()
time.sleep(2)  
#確保線程都執(zhí)行完畢
print count

import threading, time, random
count = 0
lock = threading.Lock()
def doAdd():
  
'''@summary: 將全局變量count 逐一的增加10000。
  
'''
  global count, lock
  lock.acquire()
  for i in xrange(10000):
    count = count + 1
  lock.release()
for i in range(5):
  threading.Thread(target = doAdd, args = (), name = 'thread-' + str(i)).start()
time.sleep(2)  
#確保線程都執(zhí)行完畢
print count

def __init__(self, group=None, target=None, name=None, args=(), kwargs={})

Thread.getName()
Thread.setName()
Thread.name

Thread.ident

Thread.is_alive()
Thread.isAlive()

Thread.join([timeout])

import threading, time
def doWaiting():
  print 'start waiting:', time.strftime('%H:%M:%S')
  time.sleep(3)
  print 'stop waiting', time.strftime('%H:%M:%S')
thread1 = threading.Thread(target = doWaiting)
thread1.start()
time.sleep(1) 
#確保線程thread1已經(jīng)啟動(dòng)
print 'start join'
thread1.join() 
#將一直堵塞，直到thread1運(yùn)行結(jié)束。
print 'end join'

import threading
lock = threading.Lock() 
#Lock對(duì)象
lock.acquire()
lock.acquire() 
#產(chǎn)生了死瑣。
lock.release()
lock.release()
 
import threading
rLock = threading.RLock() 
#RLock對(duì)象
rLock.acquire()
rLock.acquire() 
#在同一線程內(nèi)，程序不會(huì)堵塞。
rLock.release()
rLock.release()

Condition.notify_all()
Condition.notifyAll()

#---- Condition
#---- 捉迷藏的游戲
import threading, time
class Hider(threading.Thread):
  def __init__(self, cond, name):
    super(Hider, self).__init__()
    self.cond = cond
    self.name = name
   
  def run(self):
    time.sleep(1) 
#確保先運(yùn)行Seeker中的方法  
     
    self.cond.acquire() 
#b  
    print self.name + ': 我已經(jīng)把眼睛蒙上了'
    self.cond.notify()
    self.cond.wait() 
#c  
             
#f 
    print self.name + ': 我找到你了 ~_~'
    self.cond.notify()
    self.cond.release()
              
#g
    print self.name + ': 我贏了'  
#h
     
class Seeker(threading.Thread):
  def __init__(self, cond, name):
    super(Seeker, self).__init__()
    self.cond = cond
    self.name = name
  def run(self):
    self.cond.acquire()
    self.cond.wait()  
#a  #釋放對(duì)瑣的占用，同時(shí)線程掛起在這里，直到被notify并重新占
有瑣。
              
#d
    print self.name + ': 我已經(jīng)藏好了，你快來(lái)找我吧'
    self.cond.notify()
    self.cond.wait()  
#e
              
#h
    self.cond.release() 
    print self.name + ': 被你找到了，哎~~~'
     
cond = threading.Condition()
seeker = Seeker(cond, 'seeker')
hider = Hider(cond, 'hider')
seeker.start()
hider.start()

#---- Event
#---- 捉迷藏的游戲
import threading, time
class Hider(threading.Thread):
  def __init__(self, cond, name):
    super(Hider, self).__init__()
    self.cond = cond
    self.name = name
   
  def run(self):
    time.sleep(1) 
#確保先運(yùn)行Seeker中的方法  
     
    print self.name + ': 我已經(jīng)把眼睛蒙上了'
     
    self.cond.set()
     
    time.sleep(1)  
     
    self.cond.wait()
    print self.name + ': 我找到你了 ~_~'
     
    self.cond.set()
               
    print self.name + ': 我贏了'
     
class Seeker(threading.Thread):
  def __init__(self, cond, name):
    super(Seeker, self).__init__()
    self.cond = cond
    self.name = name
  def run(self):
    self.cond.wait()
             
    print self.name + ': 我已經(jīng)藏好了，你快來(lái)找我吧'
    self.cond.set()
     
    time.sleep(1)
    self.cond.wait()
               
    print self.name + ': 被你找到了，哎~~~'
     
cond = threading.Event()
seeker = Seeker(cond, 'seeker')
hider = Hider(cond, 'hider')
seeker.start()
hider.start()

def hello():
  print "hello, world"
t = Timer(3, hello)
t.start() 
# 3秒鐘之后執(zhí)行hello函數(shù)。

threading.active_count()
threading.activeCount()

threading.current_thread()
threading.currentThread()

threading.enumerate()

threading.setprofile(func)