Path: csiph.com!v102.xanadu-bbs.net!xanadu-bbs.net!goblin2!goblin.stu.neva.ru!newsfeed.xs4all.nl!newsfeed4.news.xs4all.nl!xs4all!post.news.xs4all.nl!not-for-mail
MIME-Version: 1.0
Date: Fri, 4 Oct 2013 01:37:20 +0800
Subject: Why didn't my threads exit correctly ?
From: =?UTF-8?B?5p2O5rSb?= <luolee.me@gmail.com>
To: python-list@python.org
Content-Type: multipart/alternative; boundary=089e013d1db24a83c004e7d9a363
Precedence: list
Newsgroups: comp.lang.python
Message-ID: <mailman.689.1380822940.18130.python-list@python.org>
Lines: 109
NNTP-Posting-Host: 2001:888:2000:d::a6
Xref: csiph.com comp.lang.python:55431

--089e013d1db24a83c004e7d9a363
Content-Type: text/plain; charset=UTF-8

Hi list,
I write an example script using threading as follow.
It look like hang when the list l_ip is empty. And any suggestion with
debug over the threading in Python ?

  1 #!/usr/bin/env python
  2 # -*- coding: utf-8 -*-
  3 import re
  4 import os
  5 import threading
  6 from Queue import Queue
  7 from time import sleep
  8
  9 l_ip = []
 10 l_result = []
 11 result = re.compile(r"[1-3] received")
 12
 13 class ping(threading.Thread):
 14     """ """
 15     def __init__(self, l_ip, l_result):
 16         threading.Thread.__init__(self)
 17         self.l_ip = l_ip
 18         #self.l_result = l_result
 19
 20     def run(self):
 21         """ """
 22         while True:
 23             try:
 24                 ip = self.l_ip.pop()
 25             except IndexError as e:
 26                 print e
 27                 break
 28             ping_out = os.popen(''.join(['ping -q -c3 ',ip]), 'r')
 29             print 'Ping ip:%s' % ip
 30             while True:
 31                 line = ping_out.readline()
 32                 if not line: break
 33                 if result.findall(line):
 34                     l_result.append(ip)
 35                     break
 36
 37 queue = Queue()
 38
 39 for i in range(1,110):
 40     l_ip.append(''.join(['192.168.1.', str(i)]))
 41 for i in xrange(10):
 42     t = ping(l_ip, l_result)
 43     t.start()
 44     queue.put(t)
 45 queue.join()
 46 print "Result will go here."
 47 for i in l_result:
 48     print 'IP %s is OK' % i

-- 
All the best!

http://luolee.me

--089e013d1db24a83c004e7d9a363
Content-Type: text/html; charset=UTF-8
Content-Transfer-Encoding: base64

PGRpdiBkaXI9Imx0ciI+PGRpdj5IaSBsaXN0LDxicj5JIHdyaXRlIGFuIGV4YW1wbGUgc2NyaXB0
IHVzaW5nIHRocmVhZGluZyBhcyBmb2xsb3cuPGJyPjwvZGl2Pkl0IGxvb2sgbGlrZSBoYW5nIHdo
ZW4gdGhlIGxpc3QgbF9pcCBpcyBlbXB0eS4gQW5kIGFueSBzdWdnZXN0aW9uIHdpdGggZGVidWcg
b3ZlciB0aGUgdGhyZWFkaW5nIGluIFB5dGhvbiA/IDxicj48ZGl2Pjxicj7CoCAxICMhL3Vzci9i
aW4vZW52IHB5dGhvbjxicj4NCsKgIDIgIyAtKi0gY29kaW5nOiB1dGYtOCAtKi08YnI+wqAgMyBp
bXBvcnQgcmU8YnI+wqAgNCBpbXBvcnQgb3M8YnI+wqAgNSBpbXBvcnQgdGhyZWFkaW5nPGJyPsKg
IDYgZnJvbSBRdWV1ZSBpbXBvcnQgUXVldWU8YnI+wqAgNyBmcm9tIHRpbWUgaW1wb3J0IHNsZWVw
PGJyPsKgIDggPGJyPsKgIDkgbF9pcCA9IFtdPGJyPsKgMTAgbF9yZXN1bHQgPSBbXTxicj7CoDEx
IHJlc3VsdCA9IHJlLmNvbXBpbGUociZxdW90O1sxLTNdIHJlY2VpdmVkJnF1b3Q7KTxicj4NCsKg
MTIgPGJyPsKgMTMgY2xhc3MgcGluZyh0aHJlYWRpbmcuVGhyZWFkKTo8YnI+wqAxNMKgwqDCoMKg
ICZxdW90OyZxdW90OyZxdW90OyAmcXVvdDsmcXVvdDsmcXVvdDs8YnI+wqAxNcKgwqDCoMKgIGRl
ZiBfX2luaXRfXyhzZWxmLCBsX2lwLCBsX3Jlc3VsdCk6PGJyPsKgMTbCoMKgwqDCoMKgwqDCoMKg
IHRocmVhZGluZy5UaHJlYWQuX19pbml0X18oc2VsZik8YnI+wqAxN8KgwqDCoMKgwqDCoMKgwqAg
c2VsZi5sX2lwID0gbF9pcDxicj7CoDE4wqDCoMKgwqDCoMKgwqDCoCAjc2VsZi5sX3Jlc3VsdCA9
IGxfcmVzdWx0PGJyPg0KwqAxOSA8YnI+wqAyMMKgwqDCoMKgIGRlZiBydW4oc2VsZik6PGJyPsKg
MjHCoMKgwqDCoMKgwqDCoMKgICZxdW90OyZxdW90OyZxdW90OyAmcXVvdDsmcXVvdDsmcXVvdDs8
YnI+wqAyMsKgwqDCoMKgwqDCoMKgwqAgd2hpbGUgVHJ1ZTo8YnI+wqAyM8KgwqDCoMKgwqDCoMKg
wqDCoMKgwqDCoCB0cnk6PGJyPsKgMjTCoMKgwqDCoMKgwqDCoMKgwqDCoMKgwqDCoMKgwqDCoCBp
cCA9IHNlbGYubF9pcC5wb3AoKTxicj7CoDI1wqDCoMKgwqDCoMKgwqDCoMKgwqDCoMKgIGV4Y2Vw
dCBJbmRleEVycm9yIGFzIGU6PGJyPg0KwqAyNsKgwqDCoMKgwqDCoMKgwqDCoMKgwqDCoMKgwqDC
oMKgIHByaW50IGU8YnI+wqAyN8KgwqDCoMKgwqDCoMKgwqDCoMKgwqDCoMKgwqDCoMKgIGJyZWFr
PGJyPsKgMjjCoMKgwqDCoMKgwqDCoMKgwqDCoMKgwqAgcGluZ19vdXQgPSBvcy5wb3BlbigmIzM5
OyYjMzk7LmpvaW4oWyYjMzk7cGluZyAtcSAtYzMgJiMzOTssaXBdKSwgJiMzOTtyJiMzOTspPGJy
PsKgMjnCoMKgwqDCoMKgwqDCoMKgwqDCoMKgwqAgcHJpbnQgJiMzOTtQaW5nIGlwOiVzJiMzOTsg
JSBpcDxicj7CoDMwwqDCoMKgwqDCoMKgwqDCoMKgwqDCoMKgIHdoaWxlIFRydWU6PGJyPg0KwqAz
McKgwqDCoMKgwqDCoMKgwqDCoMKgwqDCoMKgwqDCoMKgIGxpbmUgPSBwaW5nX291dC5yZWFkbGlu
ZSgpPGJyPsKgMzLCoMKgwqDCoMKgwqDCoMKgwqDCoMKgwqDCoMKgwqDCoCBpZiBub3QgbGluZTog
YnJlYWs8YnI+wqAzM8KgwqDCoMKgwqDCoMKgwqDCoMKgwqDCoMKgwqDCoMKgIGlmIHJlc3VsdC5m
aW5kYWxsKGxpbmUpOjxicj7CoDM0wqDCoMKgwqDCoMKgwqDCoMKgwqDCoMKgwqDCoMKgwqDCoMKg
wqDCoCBsX3Jlc3VsdC5hcHBlbmQoaXApPGJyPsKgMzXCoMKgwqDCoMKgwqDCoMKgwqDCoMKgwqDC
oMKgwqDCoMKgwqDCoMKgIGJyZWFrPGJyPsKgMzYgPGJyPg0KwqAzNyBxdWV1ZSA9IFF1ZXVlKCk8
YnI+wqAzOCA8YnI+wqAzOSBmb3IgaSBpbiByYW5nZSgxLDExMCk6PGJyPsKgNDDCoMKgwqDCoCBs
X2lwLmFwcGVuZCgmIzM5OyYjMzk7LmpvaW4oWyYjMzk7MTkyLjE2OC4xLiYjMzk7LCBzdHIoaSld
KSk8YnI+wqA0MSBmb3IgaSBpbiB4cmFuZ2UoMTApOjxicj7CoDQywqDCoMKgwqAgdCA9IHBpbmco
bF9pcCwgbF9yZXN1bHQpPGJyPsKgNDPCoMKgwqDCoCB0LnN0YXJ0KCk8YnI+wqA0NMKgwqDCoMKg
IHF1ZXVlLnB1dCh0KTxicj4NCsKgNDUgcXVldWUuam9pbigpPGJyPsKgNDYgcHJpbnQgJnF1b3Q7
UmVzdWx0IHdpbGwgZ28gaGVyZS4mcXVvdDs8YnI+wqA0NyBmb3IgaSBpbiBsX3Jlc3VsdDo8YnI+
wqA0OMKgwqDCoMKgIHByaW50ICYjMzk7SVAgJXMgaXMgT0smIzM5OyAlIGk8YnIgY2xlYXI9ImFs
bCI+PGRpdj48YnI+LS0gPGJyPjxkaXYgZGlyPSJsdHIiPjxkaXY+QWxsIHRoZSBiZXN0ITxicj48
YnI+PC9kaXY+PGRpdj48YSBocmVmPSJodHRwOi8vbHVvbGVlLm1lIiB0YXJnZXQ9Il9ibGFuayI+
aHR0cDovL2x1b2xlZS5tZTwvYT48YnI+DQo8L2Rpdj48L2Rpdj4NCjwvZGl2PjwvZGl2PjwvZGl2
Pg0K
--089e013d1db24a83c004e7d9a363--