thread_safety_queue.py

from threading import Thread
from Queue import Queue

class Adding:
	def __init__(self):
		self.added = False
		self.value = 0

	def has_added(self):
		return self.added

	def add(self):
		print "Adding...\n"
		self.value +=1
		self.added = True

	def get_value(self):
		return self.value

def do_add():	
	adding = q.get()
	adding.add()
	q.task_done()

q = Queue()
adding = Adding()
q.put(adding)
for i in xrange(5):	
	t = Thread(target=do_add)
	t.daemon = True
	t.start()

print "Value: %s" % adding.get_value()