对比Java和.NET多线程编程

这篇文章以对比的方式总结Java和.NET多线程编程。

基本概念

多线程：很多开发语言都提供多线程编程支持，比如Java，C#。

并发（concurrent）：即使对于单核CPU，我们也会采用多线程等技术提高service的并发处理能力，我们经常说的高并发，就是这个意思。

并行（parallel）：多个计算机任务能够真正在同一时刻同时执行，狭义的讲，对同一台计算机，在单核CPU时代，理论上，这是不可能的；随着计算机得硬件得发展，多核CPU使得这个成为了可能。

异步（asynchronous programming）：异步编程可以基于多线程（语言层面提供的多线程），并不是一定要基于多线程，比如说nodejs，nodejs的异步编程其实是基于事件驱动和事件循环来实现的。

阻塞（blocking）/非阻塞（non-blocking）：这两个概念更多是出现在IO的场景，比如Blocking IO（BIO）和Non-blocking IO（NIO）；其实理解这两个概念，我们可以分别类比下面会提到的BlockingQueue和CompletionService。

Java

在java中，多线程编程一般有两种方式：

  1. 使用最原生的API

  2. 使用concurrent包提供的API

1. 使用最原生的API

启动一个线程有两种方式：继承java.lang.Thread类和实现java.lang.Runnable接口。这两个类都是从java 1.0就开始有了。

线程之间同步主要是用synchronized关键字和java.lang.Object的wait()、notify()方法。

2. 使用concurrent包提供的API

其实，concurrent包提供很多功能，比如线程池相关类、阻塞队列、集合的线程安全实现等，具体可以参考concurent包的官方文档（https://docs.oracle.com/javase/8/docs/api/java/util/concurrent/package-summary.html）。

这里列举一些用过的concurrent包下API的典型例子：

1) 启动一个线程池，把要做的事情放到java.util.concurrent.Callable接口里面实现(Callable不同于Runnable接口的地方是，Callable可以有返回)，然后把Callable实现类提交给线程池管理，同时可以得到一个java.util.concurrent.Future，调用Future的get()方法可以获取Callable返回结果。

ExecutorService threadPool = Executors.newFixedThreadPool(10);List<Future<String>> futureList = new ArrayList<Future<String>>)();
for(int i = 0; i < 100; i++) {Future<String> future = threadPool.submit(new TaskCallable());futureList.add(future);
}for(Future<String> future : futureList) {System.out.println(future.get());
}threadPool.shutdown();

如果有100个Task要执行，可以使用java.util.concurrent.CountDownLatch类来等待所有Task都执行完才做下一步操作。

2) 上面示例代码中future.get()是一个阻塞动作，如果有100个Task，有可能后面的Task先执行完，这样对后面Task结果的处理就会一直pending在前面Task的future.get()调用上。concurrent包提供了另外一个API - CompletionService，可以解决这个问题。实例代码如下：

ExecutorService threadPool = Executors.newFixedThreadPool(10);CompletionService<String> completionService = new ExecutorCompletionService<String>(threadPool);for(int i = 0; i < 100; i++) {Future<String> future = completionService.submit(new TaskCallable());
}for(int i = 0; i < 100; i++) {String result = completionService.take().get();System.out.println(result);
}threadPool.shutdown();

3) 控制两个线程执行顺序，一个线程等另外一个执行完之后才能继续执行，可以用java.util.concurrent.SynchronousQueue比较容易实现；而传统的做法则是采用wait/notify。其实SynchronousQueue实现了java.util.concurrent.BlockingQueue接口，这个接口还有一些其它的实现类，比如：java.util.concurrent.ArrayBlockingQueue，当我们需要实现一个典型的生产者消费者模型时，就可以直接使用这个类。

4） HashMap的线程安全实现java.util.concurrent.ConcurrentHashMap。关于ConcurrentHashMap的实现原理，可以参考这篇文章（漫画：什么是ConcurrentHashMap？）。

5) 还有一个经常用到的就是concurrent包下面的java.util.concurrent.locks.Lock接口，这个接口有一个实现类java.util.concurrent.locks.ReentrantLock，这是一个可重入锁的实现，和上面提到的synchronized关键字的作用一样。当然，使用Lock和synchronized关键字还是有一些区别的：比如Lock可以实现公平锁，synchronized则只能是非公平锁。

6) java.util.concurrent.atomic包下面提供的原子操作类，也经常用到。当我们要实现自增长功能时，可以使用java.util.concurrent.atomic.AtomicInteger类，这个类实现自增长原子操作的原理是CAS（Compare And Set）算法，而不是加锁的方式，所以在某些情况下可能会效率高一些。关于CAS算法的原理，可以参考这篇文章（库存扣多了，到底怎么整 | 架构师之路）。

C# / .NET

对比Java里面的多线程编程实现方法，.NET里面基本上也都有对用的实现。

1) Java中的Thread类和Runnable接口；对应.NET里面就是System.Threading.Thread类和System.Threading.ThreadStart委托。

2) Java中线程同步主要用synchronized关键字；而.NET中则用lock关键字，但是lock关键字不能应用到方法上，如果要把同步加到方法上，可以用System.Runtime.Remoting.Context.Synchronization特性。

3) 除了上面提到的语言层面提供的关键字可以用于加锁，Java的concurrent包提供了Lock类；对应.NET就是System.Threading.Monitor类。

4) Java的concurrent包提供了一些原子操作的类，比如java.util.concurrent.atomic.AtomicInteger；对应.NET里面就是System.Threading.Interlocked。

5) Java的concurrent包提供了一些集合的线程安全实现，比如java.util.concurrent.ConcurrentHashMap；在.NET里面也是类似，.NET里面的System.Collections.Concurrent这个namespace下，也提供了很多集合的线程安全实现，比如System.Collections.Concurrent.ConcurrentDictionary。

6) .NET里面使用线程池实现多线程编程例子如下（See https://docs.microsoft.com/en-us/dotnet/api/system.threading.threadpool?view=netcore-3.1）：

using System;
using System.Threading;public class Example 
{public static void Main() {// Queue the task.ThreadPool.QueueUserWorkItem(ThreadProc);Console.WriteLine("Main thread does some work, then sleeps.");Thread.Sleep(1000);Console.WriteLine("Main thread exits.");}// This thread procedure performs the task.static void ThreadProc(Object stateInfo) {// No state object was passed to QueueUserWorkItem, so stateInfo is null.Console.WriteLine("Hello from the thread pool.");}
}

7) .net 4.0新增的TAP（task-based asynchronous pattern），不需要显示操作线程（CLR负责管理线程的分配），只需要关注Task，如下：

using System;
using System.Threading;
using System.Threading.Tasks;namespace ConsoleApp1
{class Program2{static void Main(string[] args){Console.WriteLine("current thread: " + Thread.CurrentThread.ManagedThreadId);// Construct a started task using Task.Run.String taskData = "delta";Task t3 = Task.Run(() => {Console.WriteLine("Task={0}, obj={1}, Thread={2}", Task.CurrentId, taskData, Thread.CurrentThread.ManagedThreadId);Thread.Sleep(1000 * 10000);});// Wait for the task to finish.//t3.Wait();Task t2 = Task.Run(() => {Console.WriteLine("Task={0}, obj={1}, Thread={2}", Task.CurrentId, taskData, Thread.CurrentThread.ManagedThreadId);});// Wait for the task to finish.t2.Wait();Console.WriteLine("end");}}
}

在.net 4.5之后，又新增了async/await关键字，这种方式基于TAP，通过这种方式可以方便的实现Task完成之后的callback逻辑，比如上面例子中想在t3执行完了之后再做一些逻辑，需要调用t3.wait()，或者调用Task.WaitAll()方法。有async/await关键字之后，可以很方便的实现，如下：

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading;
using System.Threading.Tasks;namespace ConsoleApp1
{class Program{static void Main(string[] args){TestMain();}static void TestMain(){Console.Out.Write("Start\n");GetValueAsync();Console.Out.Write("End\n");Console.ReadKey();}static async Task GetValueAsync(){await Task.Run(()=>{Thread.Sleep(1000);for(int i = 0; i < 5; ++i){Console.Out.WriteLine(String.Format("From task : {0}", i));}});Console.Out.WriteLine("Task End");}}
}

上面Console.Out.WriteLine("Task End");这行代码即是Task执行完成之后才执行的逻辑。这个有点像javascript里面的Promise.

8) .net 4.0里面还提供了并行编程的一些功能，比如：System.Threading.Tasks.Parallel。所谓并行编程，狭义的讲，就是说可以充分利用现在计算机CPU多核的优势，让运算任务在多个核上同时并行执行。更多的，可以参考（https://docs.microsoft.com/en-us/dotnet/standard/parallel-programming/）。

相关阅读

  • 从Java转向.NET/C#，Are You OK?

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/311229.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

Anaconda创建python虚拟环境

Anaconda创建python虚拟环境

在创建虚拟环境之前首先我们需要打开命令终端&#xff1a;Win R 输入cmd 或者直接打开Anaconda Prompt&#xff08;Anaconda&#xff09; pycharm下载历史版本地址&#xff1a;https://www.jetbrains.com/pycharm/download/other.html Anaconda下载历史版本地址&#xff1a;ht…
阅读更多...
vue2实践揭秘pdf_《Vue2.0 实践揭秘》终于出版啦！

vue2实践揭秘pdf_《Vue2.0 实践揭秘》终于出版啦！

不知不觉间在园子开博都两年多了&#xff0c;最近一些园友问最近去哪了为何都没有新的文章了。最近确实发生了很多的事&#xff0c;一是忙工作二就是忙着写书。这还得多些园子的小编&#xff0c;自两年前发表的“架构师修炼”系列的文章后被出版社相出让我将这个主题写成书&…
阅读更多...
[蓝桥杯][算法提高VIP]夺宝奇兵-递推+记忆化搜索

[蓝桥杯][算法提高VIP]夺宝奇兵-递推+记忆化搜索

题目描述 在一座山上,有很多很多珠宝,它们散落在山底通往山顶的每条道路上,不同道路上的珠宝的数目也各不相同.下图为一张藏宝地图: 7 3 8 8 1 0 2 7 4 4 4 5 2 6 5 ”夺宝奇兵”从山下出发,到达山顶,如何选路才能得到最多的珠宝呢?在上图所示例子中,按照5-> 7-> 8-&g…
阅读更多...
这些年我对微服务的理解

这些年我对微服务的理解

Monolith、SOA、DDD、The two-pizza rule、分库分表这些概念跟微服务有啥关系&#xff0c;你知道吗&#xff1f;这篇文章记录我的理解&#xff0c;分享给大家。微服务&#xff08;micro service&#xff09;&#xff0c;个人感觉也就近几年才吵起来的概念&#xff0c;记得退回去…
阅读更多...
梯度下降与线性回归

梯度下降与线性回归

对于代价函数&#xff1a; loss∑i(y^−yi)2loss\sum_i{(\hat{y}-y_i)}^2loss∑i​(y^​−yi​)2 loss∑i(w∗xib−yi)2loss\sum_i{(w*x_ib-y_i)}^2loss∑i​(w∗xi​b−yi​)2 最常见的代价函数&#xff1a;均方差代价函数&#xff08;Mean-Square Error&#xff0c;MSE&…
阅读更多...
fastreport字体自适应_FastReport 自动换行与行高自适应及自动增加空行

fastreport字体自适应_FastReport 自动换行与行高自适应及自动增加空行

设定后即可自动换行及行高自适应。版本号5.6.21、masterData&#xff1a;属性值&#xff1a;stretched 为True2、Memo设定wordwrap为True ,stretchMode:smMaxHeightFastReport自动增加空行1、在masterdata下增加child&#xff1b;2、在code编写如下代码varPageLine: integer;//…
阅读更多...
.NET Core开发实战（第21课：中间件：掌控请求处理过程的关键）--学习笔记（下）...

.NET Core开发实战（第21课：中间件：掌控请求处理过程的关键）--学习笔记（下）...

21 | 中间件&#xff1a;掌控请求处理过程的关键如果在 Map 的时候逻辑复杂一点&#xff0c;不仅仅判断它的 URL 地址&#xff0c;而且要做特殊的判断的话&#xff0c;可以这么做把判断逻辑变成一个委托我们要判断当我们的请求地址包含 abc 的时候&#xff0c;输出 new abcapp.…
阅读更多...
英伟达3060Ti安装GPU版本TensorFlow2.X和Pytorch

英伟达3060Ti安装GPU版本TensorFlow2.X和Pytorch

查看Python与TensorFlow对应版本 安装GPU版本的TensorFlow的时候&#xff0c;我们需要考虑的一个问题是Python版本与TensorFlow版本的对应关系&#xff0c;可以参考下面这个链接&#xff1a; Python对应TensorFlow CPU版本 GPU版本 查看显卡驱动对应的CUDA版本并且下载安装 …
阅读更多...
石子合并-区间dp

石子合并-区间dp

设有N堆石子排成一排&#xff0c;其编号为1&#xff0c;2&#xff0c;3&#xff0c;…&#xff0c;N。 每堆石子有一定的质量&#xff0c;可以用一个整数来描述&#xff0c;现在要将这N堆石子合并成为一堆。 每次只能合并相邻的两堆&#xff0c;合并的代价为这两堆石子的质量…
阅读更多...
cesium米转换经纬度_cesium 笛卡尔坐标（单位：米） 与 经纬度（单位：弧度/度） 之间的转换。...

cesium米转换经纬度_cesium 笛卡尔坐标（单位：米） 与 经纬度（单位：弧度/度） 之间的转换。...

this.model.readyPromise.then(function (tileset) {//记录模型原始的中心点var boundingSphere tileset.boundingSphere;that.boundingSphere boundingSphere;//模型原始的中心点。此处是笛卡尔坐标&#xff0c;单位&#xff1a;米。var position boundingSphere.center;//…
阅读更多...
200行代码，7个对象——让你了解ASP.NET Core框架的本质[3.x版]

200行代码，7个对象——让你了解ASP.NET Core框架的本质[3.x版]

2019年1月19日&#xff0c;微软技术&#xff08;苏州&#xff09;俱乐部成立&#xff0c;我受邀在成立大会上作了一个名为《ASP.NET Core框架揭秘》的分享。在此次分享中&#xff0c;我按照ASP.NET Core自身的运行原理和设计思想创建了一个 “迷你版” 的ASP.NET Core框架&…
阅读更多...
逻辑回归（二）

逻辑回归（二）

逻辑回归 在学习逻辑回归之前我们先回顾一下线性回归。线性回归解决的是回归问题&#xff0c;简单来说就是&#xff0c;我们需要找到一个函数&#xff0c;这个函数需要尽可能的拟合所有训练集的样本点。 逻辑回归解决的是分类问题&#xff0c;它的目标是找到一个函数&#x…
阅读更多...
ios 顶部tab滑动实现_iOS开发之多表视图滑动切换示例（仿头条客户端）

ios 顶部tab滑动实现_iOS开发之多表视图滑动切换示例（仿头条客户端）

好长时间没为大家带来iOS开发干货的东西了&#xff0c;今天给大家分享一个头条新闻客户端各个类别进行切换的一个示例。在Demo中对所需的组件进行的简单封装&#xff0c;在封装的组件中使用的是纯代码的形式&#xff0c;如果想要在项目中进行使用&#xff0c;稍微进行修改即可。…
阅读更多...
上元节的灯会(灭)-区间dp

上元节的灯会(灭)-区间dp

题目背景 上元节的庙会上&#xff0c;牛宝靠自己的聪明才智成功破解了花灯阵&#xff0c;点亮了在场所有花灯&#xff0c;但他没料到的是这个游戏包含AB两个项目&#xff0c;A项目就是点亮所有花灯&#xff0c;而B项目则是熄灭所有花灯。不过点亮的是花灯阵&#xff0c;熄灭的…
阅读更多...
Asp.Net Core 中IdentityServer4 授权中心之应用实战

Asp.Net Core 中IdentityServer4 授权中心之应用实战

一、前言查阅了大多数相关资料&#xff0c;搜索到的IdentityServer4 的应用文章大多是比较简单并且多是翻译官网的文档编写的&#xff0c;我这里在 Asp.Net Core 中IdentityServer4 的应用分析中会以一个电商系统架构升级过程中普遍会遇到的场景进行实战性讲述分析&#xff0c;…
阅读更多...
交通标志识别项目教程

交通标志识别项目教程

项目结构图 下载好项目压缩包后解压&#xff0c;得到以上的文件&#xff0c;首先将画红圈的文件删除&#xff08;如果有&#xff09; 安装软件 安装Anaconda 安装Pycharm 安装格式工厂 在上图中这个位置输入cmd回车&#xff0c;即可打开命令终端。用这样的方式打开命令终端…
阅读更多...
内存超频trfc_这只是开始？四款DDR4内存超频效果对比

内存超频trfc_这只是开始？四款DDR4内存超频效果对比

原标题&#xff1a;这只是开始&#xff1f;四款DDR4内存超频效果对比之前有人说DDR4内存的频率极限是5000MHz&#xff0c;但在最近结束的台湾电脑展上&#xff0c;有些内存的默认频率已经达到了4400MHz&#xff0c;看样子5000MHz的频率极限很快要实现了&#xff0c;由此也说明5…
阅读更多...
素数-试除法和埃式筛选法模板

素数-试除法和埃式筛选法模板

试除法&#xff1a; bool is_prime(int n) {if (n < 1) return false;for (int i 2;i<sqrt(n);i)//这样写更好!if (n % i0) return false;return true; }埃式筛选法&#xff1a; const int N 1e7; int prime[N 1]; bool vis[N 1];int n_prime(int n) {int k 0;mem…
阅读更多...
C# 视频监控系统

C# 视频监控系统

去过工厂或者仓库的都知道&#xff0c;在工厂或仓库里面&#xff0c;会有很多不同的流水线&#xff0c;大部分的工厂或仓库&#xff0c;都会在不同流水线的不同工位旁边安装一台电脑&#xff0c;一方面便于工位上的师傅把产品的重要信息录入系统&#xff0c;便于公司系统数据采…
阅读更多...
sklearn svm如何选择核函数_机器学习之支持向量机多种核模型对比

sklearn svm如何选择核函数_机器学习之支持向量机多种核模型对比

机器学习xueyifeiyun1989zx&#xff0c;公众号&#xff1a;围着围巾的小黑机器学习之监督学习实战前文我们提到机器学习中的监督学习&#xff0c;其中有一个模型是我们提到的但是没有训练测试的&#xff0c;叫做支持向量机(简称SVM)。支持向量机也是监督学习里面一个非常容易理…
阅读更多...
最新文章

Copyright @ 2022~2023