def func(vals):
    for val in vals:
        fo_something(val)

for x in range(0,n):
    thread = threading.Thread(target=func, args=[vals])
    thread.start()

tsVals = ThreadSafeGeneratorWrapper(vals)
for x in range(0,n):
    thread = threading.Thread(target=func, args=[tsVals])
    thread.start()

def func(vals):
    for val in vals:
        fo_something(val)

class LockedIterator(object):
    def __init__(self, it):
        self.lock = threading.Lock()
        self.it = it.__iter__()

    def __iter__(self): return self

    def next(self):
        self.lock.acquire()
        try:
            return self.it.next()
        finally:
            self.lock.release()