Refactor hwrng_example.py to utilize MaxRNG and implement multi-threaded RNG retrieval

Thanks to the previous changes

Author: DefinetlyNotAI

example/hwrng_example.py

@@ -1,19 +1,49 @@
-from pyCTools.hwrng import (
-    get_hardware_random_bytes,
-    get_hardware_random_bytes_threadsafe,
-    get_hardware_random_bytes_extended,
-    hardware_rng_selftest,
-)
+import os
+import threading
+import sys
 
-if __name__ == '__main__':
-    print("RNG self-test:", "PASS" if hardware_rng_selftest() else "FAIL")
+sys.path.insert(0, os.path.abspath(os.path.join(os.path.dirname(__file__), "..")))
+from pyCTools.hwrng import MaxRNG
 
+rng = MaxRNG()
+rng.dll.maxrng_init()
+
+print("RDRAND supported:", rng.test_rng_available())
+print("Threading available:", rng.test_threading_available())
+
+print("Basic RNG 32 bytes:", rng.maxrng(32).hex())
+print("Ultra RNG 32 bytes (complexity 10):", rng.maxrng_ultra(32, 10).hex())
+print("Solo Thread-safe RNG 32 bytes:", rng.maxrng_threadsafe(32).hex())
+
+
+def worker(size, index, results):
     try:
-        rb = get_hardware_random_bytes(32)
-        print("MaxRNG (32 bytes):", rb.hex())
-        rb2 = get_hardware_random_bytes_threadsafe(32)
-        print("MaxRNG_ThreadSafe (32 bytes):", rb2.hex())
-        rb3 = get_hardware_random_bytes_extended(32, intensive_level=3)
-        print("MaxRNG_Extended (32 bytes, level 3):", rb3.hex())
-    except Exception as e:
-        print("Error:", e)
+        data = rng.maxrng_threadsafe(size)
+        results[index] = data
+    except RuntimeError as e:
+        results[index] = e
+
+
+num_threads = 5
+bytes_per_thread = 16
+results_main = [None] * num_threads
+threads = []
+
+for i in range(num_threads):
+    t = threading.Thread(target=worker, args=(bytes_per_thread, i, results_main))
+    threads.append(t)
+    t.start()
+
+for t in threads:
+    t.join()
+
+for i, result in enumerate(results_main):
+    if isinstance(result, Exception):
+        print(f"Thread {i}: RNG failed: {result}")
+    else:
+        print(f"Thread {i}: got {len(result)} bytes -> {result.hex()}")
+
+print("All threads finished.")
+
+
+print("Example completed successfully.")