feat: only for download peer spawn a thread

src/peer/listen.rs

@@ -228,7 +228,13 @@ fn handle_incoming_connection(stream: TcpStream, context: ConnectionContext) {
         ConnectionType::P => handle_peer_connection(
             peer, stream, reader, &context, &peer_ip, peer_port,
         ),
-        ConnectionType::F => handle_file_connection(
+
+        ConnectionType::F => {
+            thread::spawn(move || {
+                trace!(
+                    "[listener:{peer_ip}:{peer_port}] handling file connection in thread"
+                );
+                handle_file_connection(
                     peer,
                     stream,
                     reader,
@@ -236,7 +242,9 @@ fn handle_incoming_connection(stream: TcpStream, context: ConnectionContext) {
                     &context,
                     &peer_ip,
                     peer_port,
-        ),
+                )
+            });
+        }
         ConnectionType::D => {
             debug!("[listener:{peer_ip}:{peer_port}] connection type is D, not supported yet, closing connection. ");
         }
@@ -273,7 +281,7 @@ impl Listen {
             };
 
             let context = context.clone();
-            thread::spawn(move || handle_incoming_connection(stream, context));
+            handle_incoming_connection(stream, context);
         }
     }
 }