Still have a race condition or something when ending on a producing thread. Looking into it now.