Test to see that that official p4 api can be executed multithreadded

p4_multithreadded.py

"""

    Test to see that the official p4 api can be executed multithreadded

"""

# Get time so we can cause a delay, and uniform to set it to a random float,
from time import sleep
from random import uniform

# Get the required modules for official perforce api
from P4 import P4
from P4 import P4Exception

# Import the async multiprocessing,
import concurrent.futures

messages = (
    "First!",
    "Second!"
)

# Instantiate and connect to perforce,
p4 = P4()
p4.connect()

def info(sleep_for, message):
    sleep(sleep_for)
    return p4.run_info()

def main():
    with concurrent.futures.ThreadPoolExecutor(max_workers = 2) as executor:
        tasks = {executor.submit(info, uniform(1,2), msg): msg for msg in messages}
        for future in concurrent.futures.as_completed(tasks):
            message = tasks[future]
            try:
                data = future.result()
            except Exception as e:
                print("{} generated an exception: {}".format(message, e))
            else:
                print(message)

if __name__ == '__main__':
    main()