Add examples for serial gate.

[lucteo]

No description provided.

[github-actions]

Remaining comments which cannot be posted as a review comment to avoid GitHub Rate Limit

pre-commit

---

[pre-commit] _{reported by reviewdog 🐶}

gates/examples/serial_gate-try_save_doc.cpp

Line 8 in c62d9c9

using beman::gates::serial_gate;

---

[pre-commit] _{reported by reviewdog 🐶}

gates/examples/serial_gate-try_save_doc.cpp

Line 10 in c62d9c9

using namespace beman::execution;

---

[pre-commit] _{reported by reviewdog 🐶}

gates/examples/serial_gate-try_save_doc.cpp

Line 13 in c62d9c9

int data;

---

[pre-commit] _{reported by reviewdog 🐶}

gates/examples/serial_gate-try_save_doc.cpp

Lines 17 to 19 in c62d9c9

	std::print("saving document: {}\n", d.data);
	std::this_thread::sleep_for(std::chrono::milliseconds(100));
	return just();

---

[pre-commit] _{reported by reviewdog 🐶}

gates/examples/serial_gate-try_save_doc.cpp

Line 22 in c62d9c9

serial_gate gate;

---

[pre-commit] _{reported by reviewdog 🐶}

gates/examples/serial_gate-try_save_doc.cpp

Lines 26 to 28 in c62d9c9

	auto work
	= just(std::move(d))
	| let_value(save_async);

---

[pre-commit] _{reported by reviewdog 🐶}

gates/examples/serial_gate-try_save_doc.cpp

Lines 30 to 31 in c62d9c9

	auto protected_work =
	within(gate.try_acquire(), std::move(work)); // UPDATE: speculative execution

---

[pre-commit] _{reported by reviewdog 🐶}

gates/examples/serial_gate-try_save_doc.cpp

Lines 33 to 36 in c62d9c9

	// NEW: ignore the error
	auto handle_error
	= std::move(protected_work)
	| upon_error([](busy_error) noexcept {});

---

[pre-commit] _{reported by reviewdog 🐶}

gates/examples/serial_gate-try_save_doc.cpp

Line 38 in c62d9c9

spawn(std::move(handle_error), scope.get_token());

---

[pre-commit] _{reported by reviewdog 🐶}

gates/examples/serial_gate-try_save_doc.cpp

Lines 42 to 54 in c62d9c9

	constexpr auto N = 10;
	std::thread threads[N];
	for (int i = 0; i < N; ++i) {
	threads[i] = std::thread([i]() {
	trigger_save(document{i});
	});
	}
	for (int i = 0; i < N; ++i) {
	threads[i].join();
	}
	sync_wait(scope.join());
	return 0;
	}

---

[pre-commit] _{reported by reviewdog 🐶}

gates/examples/serial_gate-work_outside_gate.cpp

Line 10 in c62d9c9

int data;

---

[pre-commit] _{reported by reviewdog 🐶}

gates/examples/serial_gate-work_outside_gate.cpp

Lines 14 to 16 in c62d9c9

	void insert(record r) {
	std::print("insert called: {}\n", r.data);
	}

---

[pre-commit] _{reported by reviewdog 🐶}

gates/examples/serial_gate-work_outside_gate.cpp

Lines 19 to 21 in c62d9c9

	void perform_logging_after_update(record r) noexcept {
	std::print("Logging after update: {}\n", r.data);
	}

---

[pre-commit] _{reported by reviewdog 🐶}

gates/examples/serial_gate-work_outside_gate.cpp

Lines 23 to 24 in c62d9c9

	serial_gate cache_gate;
	cache c;

---

[pre-commit] _{reported by reviewdog 🐶}

gates/examples/serial_gate-work_outside_gate.cpp

Lines 28 to 43 in c62d9c9

	auto update
	= just(std::move(r))
	| then([&](record r) noexcept {
	c.insert(r);
	return r;
	});
	auto protected_update =
	within(cache_gate.acquire(), std::move(update));
	// NEW
	auto with_logging
	= std::move(protected_update)
	| then(perform_logging_after_update);
	spawn(std::move(with_logging), scope.get_token());

---

[pre-commit] _{reported by reviewdog 🐶}

gates/examples/serial_gate-work_outside_gate.cpp

Lines 47 to 59 in c62d9c9

	constexpr auto N = 20;
	std::thread threads[N];
	for (int i = 0; i < N; ++i) {
	threads[i] = std::thread([i]() {
	on_record({i});
	});
	}
	for (int i = 0; i < N; ++i) {
	threads[i].join();
	}
	sync_wait(scope.join());
	return 0;
	}

[coveralls]

Coverage Report for CI Build 36473201770

Coverage decreased (-0.5%) to 98.104%

Details

• Coverage decreased (-0.5%) from the base build.
• Patch coverage: No coverable lines changed in this PR.
• 1 coverage regression across 1 file.

Uncovered Changes

No uncovered changes found.

Coverage Regressions

1 previously-covered line in 1 file lost coverage.

File	Lines Losing Coverage	Coverage
include/beman/gates/detail/synchronized_value.hpp	1	87.5%

---

Coverage Stats

Relevant Lines:	211
Covered Lines:	207
Line Coverage:	98.1%
Coverage Strength:	129.8 hits per line

---

💛 - Coveralls