leeyis
diff --git a/‎multi-threads.py
Lines changed: 37 additions & 0 deletions b/‎multi-threads.py
Lines changed: 37 additions & 0 deletions
diff --git a/‎proxyCheck.py
Lines changed: 0 additions & 126 deletions b/‎proxyCheck.py
Lines changed: 0 additions & 126 deletions
@@ -0,0 +1,37 @@
+# -*- coding:utf-8 -*-
+import threading
+import Queue
+'''
+多线程使用模板
+'''
+SHARE_Q = Queue.Queue()  #构造一个不限制大小的的队列
+_WORKER_THREAD_NUM = 3   #设置线程个数
+
+class MyThread(threading.Thread) :
+    def __init__(self, func) :
+        super(MyThread, self).__init__()
+        self.func = func
+    def run(self) :
+        self.func()
+
+def worker() :
+    global SHARE_Q
+    while not SHARE_Q.empty():
+        item = SHARE_Q.get() #获得任务
+        print "Processing : %s\n" % item
+        # time.sleep(1)
+def main() :
+    global SHARE_Q
+    threads = []
+    for task in xrange(1000) :  #向队列中放入任务
+        SHARE_Q.put(task)
+
+    for i in xrange(_WORKER_THREAD_NUM) :
+        thread = MyThread(worker)
+        thread.start()
+        threads.append(thread)
+
+    for thread in threads :
+        thread.join()
+if __name__ == '__main__':
+    main()