prio_queue_test.py

with self.lock:
  current_list = namespace[name]

new_list = []
for element in current_list:
  element.do_the_stuff()
  if element.isAlive():
    new_list.append(element)

with self.lock:
  namespace[name] = new_list
  
  
  
# _____________________________________


with self.lock:
  entry = get_first_entry_from_prio_queue()

entry.do_the_thing()
if entry.isAlive():
  with self.lock():
    insert_again_into_prio_queue(entry)

with self.lock:
  current_list = namespace[name]

new_list = [i for i in current_list if i.do_the_stuff().isAlive()]

with self.lock:
  namespace[name] = new_list

I have solved like this:

new_list = []
with self.lock:
  current_list = ns[name]
  for item in current_list:
    do_checkings()
    if item.isAlive():
      new_list.append(item)
  ns[name] = new_list

for item in new_list:
  item.do_lenghty_job()