Use base thread
@@ -16,6 +16,7 @@ use std::net::Shutdown;
use common_base::tokio::net::TcpStream;
use common_base::Runtime;
+use common_base::Thread;
use common_base::TrySpawn;
use common_exception::ErrorCode;
use common_exception::Result;
@@ -35,7 +36,7 @@ impl MySQLConnection {
let non_blocking_stream = TcpStream::from_std(blocking_stream)?;
let query_executor = Runtime::with_worker_threads(1)?;
- std::thread::spawn(move || {
+ Thread::spawn(move || {
let join_handle = query_executor.spawn(async move {
let client_addr = non_blocking_stream.peer_addr().unwrap().to_string();
let interactive_worker = InteractiveWorker::create(session, client_addr);
