Crate thread_counter

A lightweight, thread-safe library for counting and synchronizing concurrent operations.

This crate provides a ThreadCounter type that can be used to keep track of the number of active threads or operations, and to synchronize the completion of these operations. It’s particularly useful for scenarios where you need to wait for a group of tasks to complete before proceeding.

Features

• Thread-safe counting of active operations.
• RAII-based automatic decrementing using Tickets.
• Ability to wait for all operations to complete, with optional timeout.

Usage

Here’s a basic example of how to use the ThreadCounter:

use std::{thread, time::Duration};
use thread_counter::ThreadCounter;

let counter = ThreadCounter::default();

// Spawn some threads
for _ in 0..5 {
	thread::spawn(move || {
		// Take a ticket, incrementing the counter.
		let ticket = counter.ticket();
		// Simulate some work
		thread::sleep(Duration::from_millis(100));
		// `ticket` is automatically dropped here, decrementing the counter
	});
}

// Wait for all threads to complete, timing out after 200ms.
counter.wait(Duration::from_millis(200));
println!("All threads have completed!");

Structs

RawThreadCounter

The internal implementation of the thread counter.

ThreadCounter

A thread-safe counter for tracking the number of active threads or operations.

Ticket

A RAII guard for automatically managing the thread count.