blasthavers/minicrossterm
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Quick fix logging example

Browse Source
This commit is contained in:
TimonPost 2018-08-11 18:08:26 +02:00
parent e1bbf1689f
commit 74ef83bb3f
1 changed files with 5 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
examples/program_examples/logging.rs
View File

@ -109,10 +109,12 @@ fn handle_incoming_logs(more_jobs_rx: SyncFlagRx, queue: WorkQueue<String>)
while more_jobs_rx.get().unwrap() { while more_jobs_rx.get().unwrap() {
// If work is available, do that work. // If work is available, do that work.
if let Some(work) = queue.get_work() { if let Some(work) = queue.get_work() {
let mut log = work;
log.push('\n');
// write the log // write the log
write!(screen, "{}\n", work); screen.stdout.write_string(log);
screen.flush(); screen.stdout.flush();
} }
std::thread::yield_now(); std::thread::yield_now();
} }
@ -134,7 +136,7 @@ fn log_with_different_threads(more_jobs_tx: SyncFlagTx, queue: WorkQueue<String>
let thread = thread::spawn(move || { let thread = thread::spawn(move || {
// log 400 messages // log 400 messages
for log_entry_count in 1..400 for log_entry_count in 1..10000
{ {
thread_queue.add_work(format!("Log {} from thread {} ",log_entry_count, thread_num)); thread_queue.add_work(format!("Log {} from thread {} ",log_entry_count, thread_num));
more_jobs.set(true); more_jobs.set(true);