Brian Smith sirwart

## .block
license: mit

## web_crawler_lock.py
# -*- coding: utf-8 -*-
import httplib
import re
import threadingq
from urlparse import urlsplit

class ConcurrentWorker(object):
    def __init__(self, num_threads, first_task):
        self.task_queue = [first_task]
        self.lock = threading.Condition()
	# -- coding: utf-8 --
	import httplib
	import re
	import threadingq
	from urlparse import urlsplit

	class ConcurrentWorker(object):
	def __init__(self, num_threads, first_task):
	self.task_queue = [first_task]
	self.lock = threading.Condition()