chore(multi-threaded examples: Added keyring examples

Author: RitvikKapila

examples/test/multithreaded/__init__.py

@@ -0,0 +1,3 @@
+# Copyright Amazon.com Inc. or its affiliates. All Rights Reserved.
+# SPDX-License-Identifier: Apache-2.0
+"""Stub module indicator to make linter configuration simpler."""

examples/test/multithreaded/test_i_raw_aes_keyring_multithreaded_example.py

@@ -0,0 +1,23 @@
+# Copyright Amazon.com Inc. or its affiliates. All Rights Reserved.
+# SPDX-License-Identifier: Apache-2.0
+"""Test suite for the Raw AES keyring example with multi-threading."""
+from concurrent.futures import ThreadPoolExecutor, as_completed
+import pytest
+
+from ...src.raw_aes_keyring_example import encrypt_and_decrypt_with_keyring
+
+pytestmark = [pytest.mark.examples]
+
+
+def test_encrypt_and_decrypt_with_keyring(n_threads=10):
+    """Test function for multi-threaded encrypt and decrypt using the Raw AES Keyring example."""
+    with ThreadPoolExecutor(max_workers=n_threads) as executor:
+        thread_futures = {executor.submit(encrypt_and_decrypt_with_keyring): i for i in range(n_threads)}
+
+        for future in as_completed(thread_futures):
+            thread_id = thread_futures[future]
+            try:
+                result = future.result()
+                print(f"Thread {thread_id} passed with result: {result}")
+            except Exception as e:
+                raise e

examples/test/multithreaded/test_i_raw_rsa_keyring_multithreaded_example.py

@@ -0,0 +1,23 @@
+# Copyright Amazon.com Inc. or its affiliates. All Rights Reserved.
+# SPDX-License-Identifier: Apache-2.0
+"""Test suite for the Raw RSA keyring example with multi-threading."""
+from concurrent.futures import ThreadPoolExecutor, as_completed
+import pytest
+
+from ...src.raw_rsa_keyring_example import encrypt_and_decrypt_with_keyring
+
+pytestmark = [pytest.mark.examples]
+
+
+def test_encrypt_and_decrypt_with_keyring(n_threads=10):
+    """Test function for multi-threaded encrypt and decrypt using the Raw RSA Keyring example."""
+    with ThreadPoolExecutor(max_workers=n_threads) as executor:
+        thread_futures = {executor.submit(encrypt_and_decrypt_with_keyring): i for i in range(n_threads)}
+
+        for future in as_completed(thread_futures):
+            thread_id = thread_futures[future]
+            try:
+                result = future.result()
+                print(f"Thread {thread_id} passed with result: {result}")
+            except Exception as e:
+                raise e