concurrent queue initial implementation