Java和Rust在实现多线程编程时的异同.pdfVIP

Java和Rust在实现多线程编程时的异同 这个题目是希望程序员能够用生产者和消费者这样的模式来解决匹配的问题。在我的Java和 Rust 的实现里，都是分为这么几个对象：dancetype，leader，follower，invitation。其中leader 就相当于生产者，follow就相当于消费者，invitation就是中间传递的消息。整个程序的思路就是： leader通过发送invitation给follower，folower根据自己匹配的情况返回结果给leader，接受或 者拒绝。 Java 的实现 打开Follower.java里的这个函数 这里的 Follower.this.invitations 就是我们的消息队列，定义是： private LinkedListInvitation invitations;LinkedList不是线性安全的集合，需要我们加同步。具体的 同步方法就是函数里写的，通过Java常见的用wait，notify和notifyall给对象加锁。 处理并发有 wait 、notify 和 notiyall ，有兴趣的朋友可以去这里了解一下： /16453.html。Follower就是一个等待leader发送invitation，处理并 返回结果的过程。 Leader.java 这么一段代码： 里面就是Leader发送邀请inv，并等待follower返回结果的大概逻辑，通过对消息体加锁，是 Java传统的实现多线程并发的方式。还有消费者的消息队列也会加锁，在Java里，有个对象叫 LinkedBlockingQueue，是不用加锁就可以put 和 take 的，但在例子里，我们选用了更简单的 LinkedList，也是为了表现一下加锁的逻辑。 Rust 的实现 Leader 的结构为： Follower的结构为： 对于其他语言转过来的同学，这里的Vec，i32，bool都很好理解，不过里面出现的Arc和Mutex， Sender，Receiver就是新东西了，上面这4个都是Rust标准库的东西，也是这次分享要介绍的重点 对象，是这4个东西共同实现了消息的生产，传递和消费。 下面简单介绍一下分别是做什么用的： ArcT实现了sync接口。Sync接口是做什么呢？权威资料是这么说的：当一个类型T实现了 Sync，它向编译器表明这个类型在多线程并发时没有导致内存不安全的可能性。 如果看不懂不要紧，我们先看看实际中是怎么用的： 在这个例子里，我们关注这几句： let data = Arc::new(Mutex::new(vec![1u32, 2, 3])); let data = data.clone(); let mut data = data.lock().unwrap(); 下面分别解释一下是做什么的： 简单的说Arc::new表明了这是通过clone()方法来使用的，每clone，都会给该对象原子计数+1， 通过引用计数的方法来保证对象只要还被其中任何一个线程引用就不会被释放掉，从而保证了前面说 的：这个类型在多线程并发时没有导致内存不安全的可能性。 如果我们不定义为Arc就传到其他线程使用，编译器会报： error: capture of moved value: `data` data[i] += 1; 我们可以记住clone()就是Arc 的用法。 接下来我们看Mutex： Mutex实现了send接口。同样，在权威资料里是这么描述的：这个类型的所有权可以在线程间 安全的转移 那我们又是怎么用Mutex 的呢？就是用lock().unwrap()。lock()的作用是获取对象，如果当前 有其他线程正在使用MutexT里面的T对象时，本线程就会阻塞，从而保证同时只有一个线程来访 问对象，mutex也另外提供了try_lock()的方法，是不阻塞的，只要其他线程被占用，就返回err， 通常Arc和Mutex都是一起使用的。 回到我最原