fix
This commit is contained in:
		
							parent
							
								
									91e6122819
								
							
						
					
					
						commit
						efb6022eba
					
				@ -4,7 +4,6 @@
 | 
				
			|||||||
// A blocking multi-consumer/multi-producer thread safe queue.
 | 
					// A blocking multi-consumer/multi-producer thread safe queue.
 | 
				
			||||||
// Has max capacity and supports timeout on push or pop operations.
 | 
					// Has max capacity and supports timeout on push or pop operations.
 | 
				
			||||||
 | 
					
 | 
				
			||||||
#include <cstddef>
 | 
					 | 
				
			||||||
#include <chrono>
 | 
					#include <chrono>
 | 
				
			||||||
#include <memory>
 | 
					#include <memory>
 | 
				
			||||||
#include <queue>
 | 
					#include <queue>
 | 
				
			||||||
 | 
				
			|||||||
@ -70,8 +70,8 @@ void popper(Q* q)
 | 
				
			|||||||
	string output;
 | 
						string output;
 | 
				
			||||||
	while(active)
 | 
						while(active)
 | 
				
			||||||
	{		
 | 
						{		
 | 
				
			||||||
		//q->pop(output);			
 | 
					 | 
				
			||||||
		q->clear();
 | 
							q->clear();
 | 
				
			||||||
 | 
							//q->pop(output);
 | 
				
			||||||
		++pop_count;
 | 
							++pop_count;
 | 
				
			||||||
	}
 | 
						}
 | 
				
			||||||
}
 | 
					}
 | 
				
			||||||
 | 
				
			|||||||
		Loading…
	
	
			
			x
			
			
		
	
		Reference in New Issue
	
	Block a user