refactor(rust): remove unnecessary usage of crossbeam

This removes a large dependency which should improve our build speed a bit.

Note: mpsc::channel is now a port of crossbeam, they have no difference.

See: `rust-lang/rust#93563

Cargo.toml

@@ -24,8 +24,6 @@ better_scoped_tls = { version = "0.1.0" }
 bitflags = { version = "1.3.2" }
 clap = { version = "4" }
 colored = { version = "2.0.0" }
-crossbeam = { version = "0.8.1" }
-crossbeam-channel = { version = "0.5.6" }
 dashmap = { version = "5.4.0" }
 derivative = { version = "2.2.0" }
 derive_builder = { version = "0.11.2" }

crates/rspack/Cargo.toml

@@ -22,7 +22,6 @@ xshell = "0.2.2"
 mimalloc-rust = { workspace = true }
 
 [dependencies]
-crossbeam = { workspace = true }
 dashmap = { workspace = true }
 rspack_core = { path = "../rspack_core" }
 rspack_fs = { path = "../rspack_fs", features = ["async", "rspack-error"] }

crates/rspack_core/Cargo.toml

@@ -10,7 +10,6 @@ anyhow = { workspace = true }
 async-scoped = { workspace = true, features = ["use-tokio"] }
 async-trait = { workspace = true }
 bitflags = { workspace = true }
-crossbeam = { workspace = true }
 dashmap = { workspace = true }
 derivative = { workspace = true }
 dyn-clone = "1.0.10"

crates/rspack_loader_sass/Cargo.toml

@@ -9,7 +9,6 @@ version = "0.1.0"
 
 [dependencies]
 async-trait = { workspace = true }
-crossbeam-channel = { workspace = true }
 itertools = { workspace = true }
 once_cell = { workspace = true }
 regex = { workspace = true }

crates/rspack_loader_sass/src/lib.rs

@@ -4,10 +4,9 @@ use std::{
  env,
  iter::Peekable,
  path::{Path, PathBuf},
- sync::Arc,
+ sync::{mpsc, Arc},
 };
 
-use crossbeam_channel::{unbounded, Sender};
 use itertools::Itertools;
 use once_cell::sync::Lazy;
 use regex::Regex;
@@ -350,7 +349,8 @@ impl LegacyImporter for RspackImporter {
 
 #[derive(Debug)]
 struct RspackLogger {
- tx: Sender<Vec<Diagnostic>>,
+ // `Sync` is required by the `Logger` trait
+ tx: mpsc::SyncSender<Vec<Diagnostic>>,
 }
 
 impl Logger for RspackLogger {
@@ -471,7 +471,7 @@ impl Loader<CompilerContext, CompilationContext> for SassLoader {
  loader_context: &mut LoaderContext<'_, '_, CompilerContext, CompilationContext>,
  ) -> Result<()> {
  let content = loader_context.content.to_owned();
- let (tx, rx) = unbounded();
+ let (tx, rx) = mpsc::sync_channel(8);
  let logger = RspackLogger { tx };
  let sass_options = self.get_sass_options(loader_context, content.try_into_string()?, logger);
  let result = Sass::new(&self.options.__exe_path)

crates/rspack_plugin_javascript/Cargo.toml

@@ -14,7 +14,6 @@ async-trait = { workspace = true }
 base64 = "0.13"
 better_scoped_tls = { workspace = true }
 bitflags = { workspace = true }
-crossbeam-channel = { workspace = true }
 dashmap = { workspace = true }
 either = "1"
 linked_hash_set = { workspace = true }

crates/rspack_plugin_javascript/src/ast/minify.rs

@@ -1,4 +1,4 @@
-use std::sync::Arc;
+use std::sync::{mpsc, Arc};
 
 use rspack_core::ModuleType;
 use rspack_error::{internal_error, DiagnosticKind, Error, Result, TraceableError};
@@ -235,7 +235,7 @@ fn minify_file_comments(
 
 // keep this private to make sure with_rspack_error_handler is safety
 struct RspackErrorEmitter {
- tx: crossbeam_channel::Sender<rspack_error::Error>,
+ tx: mpsc::Sender<rspack_error::Error>,
  source_map: Arc<SourceMap>,
  title: String,
  kind: DiagnosticKind,
@@ -279,7 +279,7 @@ pub fn with_rspack_error_handler<F, Ret>(
 where
  F: FnOnce(&Handler) -> Result<Ret>,
 {
- let (tx, rx) = crossbeam_channel::unbounded();
+ let (tx, rx) = mpsc::channel();
  let emitter = RspackErrorEmitter {
  title,
  kind,

crates/rspack_plugin_javascript/src/plugin.rs

@@ -1,7 +1,7 @@
 use std::hash::{Hash, Hasher};
+use std::sync::mpsc;
 
 use async_trait::async_trait;
-use crossbeam_channel::unbounded;
 use rayon::prelude::*;
 use rspack_core::rspack_sources::{
  BoxSource, ConcatSource, MapOptions, RawSource, Source, SourceExt, SourceMap, SourceMapSource,
@@ -519,15 +519,15 @@ impl Plugin for JsPlugin {
  let minify_options = &compilation.options.builtins.minify_options;
 
  if let Some(minify_options) = minify_options {
- let (tx, rx) = unbounded::<Vec<Diagnostic>>();
+ let (tx, rx) = mpsc::channel::<Vec<Diagnostic>>();
 
  compilation
  .assets
  .par_iter_mut()
  .filter(|(filename, _)| {
  filename.ends_with(".js") || filename.ends_with(".cjs") || filename.ends_with(".mjs")
  })
- .try_for_each(|(filename, original)| -> Result<()> {
+ .try_for_each_with(tx, |tx, (filename, original)| -> Result<()> {
  // In theory, if a js source is minimized it has high possibility has been tree-shaked.
  if original.get_info().minimized {
  return Ok(());
@@ -574,7 +574,6 @@ impl Plugin for JsPlugin {
  Ok(())
  })?;
 
- drop(tx);
  compilation.push_batch_diagnostic(rx.into_iter().flatten().collect::<Vec<_>>());
  }