From e106bf94eff07d9a59771d9ccc4406421e18ab64 Mon Sep 17 00:00:00 2001
From: Daniel Baumann <daniel.baumann@progress-linux.org>
Date: Sat, 4 May 2024 19:35:20 +0200
Subject: Adding upstream version 3.0.36.

Signed-off-by: Daniel Baumann <daniel.baumann@progress-linux.org>
---
 examples/progress-bar/many-parallel-tasks.py | 46 ++++++++++++++++++++++++++++
 1 file changed, 46 insertions(+)
 create mode 100755 examples/progress-bar/many-parallel-tasks.py

(limited to 'examples/progress-bar/many-parallel-tasks.py')

diff --git a/examples/progress-bar/many-parallel-tasks.py b/examples/progress-bar/many-parallel-tasks.py
new file mode 100755
index 0000000..dc34ef2
--- /dev/null
+++ b/examples/progress-bar/many-parallel-tasks.py
@@ -0,0 +1,46 @@
+#!/usr/bin/env python
+"""
+More complex demonstration of what's possible with the progress bar.
+"""
+import threading
+import time
+
+from prompt_toolkit import HTML
+from prompt_toolkit.shortcuts import ProgressBar
+
+
+def main():
+    with ProgressBar(
+        title=HTML("<b>Example of many parallel tasks.</b>"),
+        bottom_toolbar=HTML("<b>[Control-L]</b> clear  <b>[Control-C]</b> abort"),
+    ) as pb:
+
+        def run_task(label, total, sleep_time):
+            for i in pb(range(total), label=label):
+                time.sleep(sleep_time)
+
+        threads = [
+            threading.Thread(target=run_task, args=("First task", 50, 0.1)),
+            threading.Thread(target=run_task, args=("Second task", 100, 0.1)),
+            threading.Thread(target=run_task, args=("Third task", 8, 3)),
+            threading.Thread(target=run_task, args=("Fourth task", 200, 0.1)),
+            threading.Thread(target=run_task, args=("Fifth task", 40, 0.2)),
+            threading.Thread(target=run_task, args=("Sixth task", 220, 0.1)),
+            threading.Thread(target=run_task, args=("Seventh task", 85, 0.05)),
+            threading.Thread(target=run_task, args=("Eight task", 200, 0.05)),
+        ]
+
+        for t in threads:
+            t.daemon = True
+            t.start()
+
+        # Wait for the threads to finish. We use a timeout for the join() call,
+        # because on Windows, join cannot be interrupted by Control-C or any other
+        # signal.
+        for t in threads:
+            while t.is_alive():
+                t.join(timeout=0.5)
+
+
+if __name__ == "__main__":
+    main()
-- 
cgit v1.2.3