Rust mpsc::Sender cannot be shared between threads?

by

Sender cannot be shared between threads, but it can be sent!

It implements the trait Send but not Sync (Sync: Safe to access shared reference to Sender across threads).

The design of channels intends that you .clone() the sender and pass it as a value to a thread (for each thread you have). You are missing the move keyword on the thread’s closure, which instructs the closure to capture variables by taking ownership of them.

If you must share a single channel endpoint between several threads, it must be wrapped in a mutex. Mutex<Sender<T>> is Sync + Send where T: Send.

Interesting implementation note: The channel starts out for use as a stream where it has a single producer. The internal data structures are upgraded to a multi-producer implementation the first time a sender is cloned.

You may use std::sync::mpsc::SyncSender from the standard library. The diffrenece is that it implements the Sync trait but it will may block if there is no space in the internal buffer while sending a message.

For more information:

More Related Contents:

  1. How can I pass a reference to a stack variable to a thread?
  2. How do I share a mutable object between threads using Arc?
  3. Thread references require static lifetime?
  4. How do I run parallel threads of computation on a partitioned array?
  5. What is a race condition?
  6. How to create threads in nodejs
  7. How to avoid Not on FX application thread; currentThread = JavaFX Application Thread error?
  8. What is a semaphore?
  9. What is the Re-entrant lock and concept in general?
  10. What does threadsafe mean?
  11. Which would be better for concurrent tasks on node.js? Fibers? Web-workers? or Threads?
  12. Asynchronous vs Multithreading – Is there a difference?
  13. How to Multi-thread an Operation Within a Loop in Python
  14. How many memory barriers instructions does an x86 CPU have?
  15. How Do I Choose Between the Various Ways to do Threading in Delphi?
  16. Simple Thread Sample Delphi
  17. How would you define a pool of goroutines to be executed at once?
  18. How JavaFX application thread works?
  19. Is non-blocking I/O really faster than multi-threaded blocking I/O? How?
  20. Python 2.7: streaming HTTP server supporting multiple connections on one port
  21. How to manage db connections on server?
  22. Can x86 reorder a narrow store with a wider load that fully contains it?
  23. Conditional Variable vs Semaphore
  24. Using HttpContext.Current in WebApi is dangerous because of async
  25. Are “data races” and “race condition” actually the same thing in context of concurrent programming
  26. Asynchronous IO in Scala with futures
  27. How do I Understand Read Memory Barriers and Volatile
  28. Canonical way to generate random numbers in Cython
  29. Can a hyper-threaded processor core execute two threads at the exact same time?
  30. Prolog find all paths Implementation

Leave a Comment