fix concurrentqueue implementation