diff --git a/vnt/src/channel/channel.rs b/vnt/src/channel/channel.rs index 60dd83f..0b82474 100644 --- a/vnt/src/channel/channel.rs +++ b/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(); diff --git a/vnt/src/handle/tun_tap/tap_handler.rs b/vnt/src/handle/tun_tap/tap_handler.rs index 4cf2c26..4440f85 100644 --- a/vnt/src/handle/tun_tap/tap_handler.rs +++ b/vnt/src/handle/tun_tap/tap_handler.rs @@ -29,7 +29,7 @@ pub fn start(worker: VntWorker, sender: ChannelSender, ip_route: Option, ip_proxy_map: Option, 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(); diff --git a/vnt/src/handle/tun_tap/tun_handler.rs b/vnt/src/handle/tun_tap/tun_handler.rs index 7d9b177..8cf9c0c 100644 --- a/vnt/src/handle/tun_tap/tun_handler.rs +++ b/vnt/src/handle/tun_tap/tun_handler.rs @@ -66,7 +66,7 @@ pub async fn start(worker: VntWorker, sender: ChannelSender, ip_route: Option, ip_proxy_map: Option, 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();