How should I store/load my data for network storage?

import queue
import threading
import time

# Function to simulate data production (enqueueing)
def producer(q, items):
    for item in items:
        print(f"Producing {item}")
        q.put(item)  # Add item to the queue
        time.sleep(1)  # Simulate time-consuming production

# Function to simulate data consumption (dequeueing)
def consumer(q):
    while True:
        item = q.get()  # Remove and return an item from the queue
        if item is None:
            break  # None is used as a signal to stop the consumer
        print(f"Consuming {item}")
        q.task_done()  # Signal that a formerly enqueued task is complete

# Create a FIFO queue
q = queue.Queue()

# List of items to be produced
items = [1, 2, 3, 4, 5]

# Start producer thread
producer_thread = threading.Thread(target=producer, args=(q, items))
producer_thread.start()

# Start consumer thread
consumer_thread = threading.Thread(target=consumer, args=(q,))
consumer_thread.start()

# Wait for all items to be produced
producer_thread.join()

# Signal the consumer to terminate
q.put(None)

# Wait for the consumer to finish processing
consumer_thread.join()

import queue
import threading
import time

# Function to simulate data production (enqueueing)
def producer(q, items):
    for item in items:
        print(f"Producing {item}")
        q.put(item)  # Add item to the queue
        time.sleep(1)  # Simulate time-consuming production

# Function to simulate data consumption (dequeueing)
def consumer(q):
    while True:
        item = q.get()  # Remove and return an item from the queue
        if item is None:
            break  # None is used as a signal to stop the consumer
        print(f"Consuming {item}")
        q.task_done()  # Signal that a formerly enqueued task is complete

# Create a FIFO queue
q = queue.Queue()

# List of items to be produced
items = [1, 2, 3, 4, 5]

# Start producer thread
producer_thread = threading.Thread(target=producer, args=(q, items))
producer_thread.start()

# Start consumer thread
consumer_thread = threading.Thread(target=consumer, args=(q,))
consumer_thread.start()

# Wait for all items to be produced
producer_thread.join()

# Signal the consumer to terminate
q.put(None)

# Wait for the consumer to finish processing
consumer_thread.join()

nvidia-smi

nvidia-smi