调整任务数

vnt/src/channel/channel.rs

@@ -440,7 +440,7 @@ impl Channel {
                        symmetric_channel_num: usize,//对称网络，则再加一组监听，提升打洞成功率
                        relay: bool,
     ) {
-        let (buf_sender, buf_receiver) = buf_channel_group(6);
+        let (buf_sender, buf_receiver) = buf_channel_group(std::thread::available_parallelism().unwrap().get());
         for mut buf_receiver in buf_receiver.0 {
             let context = self.context.clone();
             let handler = self.handler.clone();

vnt/src/handle/tun_tap/tap_handler.rs

@@ -29,7 +29,7 @@ pub fn start(worker: VntWorker, sender: ChannelSender,
              ip_route: Option<ExternalRoute>,
              ip_proxy_map: Option<IpProxyMap>,
              client_cipher: Cipher, server_cipher: Cipher) {
-    let (buf_sender, buf_receiver) = buf_channel_group(6);
+    let (buf_sender, buf_receiver) = buf_channel_group(thread::available_parallelism().unwrap().get());
     for mut buf_receiver in buf_receiver.0 {
         let sender = sender.clone();
         let device_writer = device_writer.clone();

vnt/src/handle/tun_tap/tun_handler.rs

@@ -66,7 +66,7 @@ pub async fn start(worker: VntWorker, sender: ChannelSender,
                    ip_route: Option<ExternalRoute>,
                    ip_proxy_map: Option<IpProxyMap>,
                    client_cipher: Cipher, server_cipher: Cipher) {
-    let (buf_sender, buf_receiver) = buf_channel_group(6);
+    let (buf_sender, buf_receiver) = buf_channel_group(thread::available_parallelism().unwrap().get());
     for mut buf_receiver in buf_receiver.0 {
         let sender = sender.clone();
         let device_writer = device_writer.clone();