def METHOD_NAME(self):
    """Verify that ContextDict overrides properly within threads"""
    rets = []
    def tgt(x, s):
        inner_ret = []
        over = self.cd.clone()
        inner_ret.append(self.cd.get("foo"))
        with over:
            inner_ret.append(over.get("foo"))
            over["foo"] = x
            inner_ret.append(over.get("foo"))
            time.sleep(s)
            inner_ret.append(over.get("foo"))
            rets.append(inner_ret)
    threads = []
    for x in range(0, self.num_concurrent_tasks):
        s = self.num_concurrent_tasks - x
        t = threading.Thread(target=tgt, args=(x, s))
        t.start()
        threads.append(t)
    for t in threads:
        t.join()
    for r in rets:
        self.assertEqual(r[0], r[1])
        self.assertEqual(r[2], r[3])