fix concurrent queue