update upload

serve/upload.py

@@ -12,6 +12,11 @@ ssh_client = None
 sftp_client = None
 sftp_client_imgs = None
 
+def open_sftp():
+    global ssh_client
+    sftp_client = ssh_client.open_sftp()
+    return sftp_client
+
 def create_ssh_client(server, port, user, password):
     global ssh_client, sftp_client, sftp_client_imgs
     ssh_client = paramiko.SSHClient()
@@ -22,12 +27,12 @@ def create_ssh_client(server, port, user, password):
     transport = ssh_client.get_transport()
     transport.set_keepalive(60)
 
-    sftp_client = ssh_client.open_sftp()
-    sftp_client_1 = ssh_client.open_sftp()
-    sftp_client_2 = ssh_client.open_sftp()
-    sftp_client_3 = ssh_client.open_sftp()
-    sftp_client_4 = ssh_client.open_sftp()
-    sftp_client_imgs = [sftp_client_1, sftp_client_2, sftp_client_3, sftp_client_4]
+    with concurrent.futures.ThreadPoolExecutor() as executor:
+        futures = [executor.submit(ssh_client) for _ in range(5)]
+        results = [future.result() for future in futures]
+
+    sftp_client = results[0]
+    sftp_client_imgs = results[1:]
 
 
 def is_connected():