Ticket #8395: lockfree2.patch

queue.hpp

@@ -117 +117 @@
     };
 
     typedef typename detail::extract_allocator<bound_args, node>::type node_allocator;
-    typedef typename detail::select_freelist<node, node_allocator, compile_time_sized, fixed_sized, capacity>::type pool_t;
+    
+    struct initialised_node_allocator : node_allocator
+    {
+        initialised_node_allocator()
+        {
+        }
+
+        initialised_node_allocator( const node_allocator& a ) :
+            node_allocator(a)
+        {
+        }
+
+        typename node_allocator::pointer allocate( 
+            typename node_allocator::size_type n, 
+            typename node_allocator::const_pointer hint=0 )
+        {
+            typename node_allocator::pointer p = node_allocator::allocate(n,hint);
+            memset(p,0,sizeof(*p)*n);
+            return p;
+        }
+    };
+
+    typedef typename detail::select_freelist<node, initialised_node_allocator, compile_time_sized, fixed_sized, capacity>::type pool_t;
     typedef typename pool_t::tagged_node_handle tagged_node_handle;
     typedef typename detail::select_tagged_handle<node, node_based>::handle_type handle_type;
 
@@ -191 +213 @@
     explicit queue(size_type n):
         head_(tagged_node_handle(0, 0)),
         tail_(tagged_node_handle(0, 0)),
-        pool(node_allocator(), n + 1)
+        pool(initialised_node_allocator(), n + 1)
     {
         BOOST_ASSERT(!has_capacity);
         initialize();