diff options
author | Dennis Kobert <dennis@kobert.dev> | 2020-01-12 12:40:13 +0100 |
---|---|---|
committer | Dennis Kobert <dennis@kobert.dev> | 2020-01-12 12:40:13 +0100 |
commit | 0f9b907deef5129141c0be52db12f6c0e8c054a4 (patch) | |
tree | ce5aff724d1a1a471cf8d7102d1da75517c6cf6c /src/solvers/gpu/output.rs | |
parent | 809c4a251a3935b674571b605f2be475babe5cbb (diff) |
ParallelIterator for results
Diffstat (limited to 'src/solvers/gpu/output.rs')
-rw-r--r-- | src/solvers/gpu/output.rs | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/src/solvers/gpu/output.rs b/src/solvers/gpu/output.rs index 6bf7bcb..9030586 100644 --- a/src/solvers/gpu/output.rs +++ b/src/solvers/gpu/output.rs @@ -19,6 +19,9 @@ impl InBuffer { } fn read(&mut self) -> Option<Vec<RowResult>> { loop { + //println!("{:?}", self.receiver.recv().unwrap()); + //continue; + match self .receiver .recv() @@ -109,6 +112,7 @@ impl Output { if let Some(walls) = self.input.read() { for wall in walls { if !self.results.contains(&wall) { + wall.output(); self.result_sender .send(Message::RowResult(wall.clone())) .or_else(|_| Err(println!("Failed to transmit result back"))); |