.Net多线程编程（误用点分析）

2024-12-21 19:57:05

1 共享变量问题

错误写法：

所有的任务可能会共享同一个变量，所以输出结果可能会一样。

public static void Error()
{
   for(int i=0;i<10;i++)
   {
    Task.Run(() => { Console.WriteLine("{0}", i); });
   }
}

正确写法：

将变量i赋给局部变量temp，使得每一个任务使用不同的i值。

public static void Right()
{
   for (int i = 0; i < 10; i++)
   {
    int temp = i;
    Task.Run(() => { Console.WriteLine("{0}", temp); });
   }
}

2 不要清理挂起任务所需资源

错误写法：

异步输出文本内容，所以在未使用完StreamReader的时候，变量sr已经离开它的作用域，调用Dispose方法。

public static void Error()
{
   using (StreamReader sr = new StreamReader(@"D:\说明.txt", Encoding.Default))
   {
    Task.Run(() => { Console.WriteLine("输出：{0}",sr.ReadLine()); });
   }
}

正确写法：

public static void Right()
{
   using (StreamReader sr = new StreamReader(@"D:\说明.txt", Encoding.Default))
   {
    var task = Task.Run(() => { Console.WriteLine("输出：{0}", sr.ReadLine()); });
    task.Wait();
   }
}

3 避免锁定this，typeof(type),string

正确的做法：定义一个object类型的私有只读字段，锁定之。

4 关于WaitHandle.WaitAll的waitHandles的数目必须小于等于64个

public static void Error()
{
   ManualResetEvent[] manualEvents = new ManualResetEvent[65];

   try
   {
    for (int i = 0; i < 65; i++)
    {
     var temp = i;
     Task.Run(() =>
     {
      manualEvents[temp] = new ManualResetEvent(false);
      Console.WriteLine("{0}", temp);
      manualEvents[temp].Set();
     });
    }
    WaitHandle.WaitAll(manualEvents);
   }
   catch (Exception ae)
   {
    Console.WriteLine(ae.Message);
   }
}

5 无法捕获异常的情形

try
{
    var task = Task.Run(() => { throw new Exception("抛异常"); });
    //如果将下面这行代码注掉，则无法抛出异常
    task.Wait();
}
catch(Exception ex)
{
    Console.WriteLine(ex.Message);
}

6 是否该释放Task资源

建议调用Dispose，但不调用也不是一个严重的错误。

注意在Task任务处于某些状态时是不允许释放资源的，否则会报错。

public static void CatchException()
{
   try
   {
    Console.WriteLine("开始");
    var task = Task.Run(() =>
    {
     //throw new Exception("抛异常");
    });
    //注掉下面这行代码，观察异常结果
    //task.Wait();
    task.Dispose();
    Console.WriteLine("结束");
   }
   catch(Exception ex)
   {
    Console.WriteLine(ex.Message);
   }
}

7 死锁演示

假设tsak1和task2都在获得第二个锁（对tsak1来说它请求的第二个锁是LockedObj2 ，而对task2来说则是LockedObj1 ）之前成功获得了第一个锁，就会发生死锁。

private static readonly Object LockedObj1 = new object();
private static readonly Object LockedObj2 = new object();
public static void LockShow()
{
   var task1 = Task.Run(() =>
   {
    lock (LockedObj1)
    {
     Console.WriteLine("get LockedObj1");
     lock (LockedObj2)
     {
      Console.WriteLine("get LockedObj2....");
     }
    }
   });
   var task2 = Task.Run(() =>
   {
    lock (LockedObj2)
    {
     Console.WriteLine("get LockedObj2");
     lock (LockedObj1)
     {
      Console.WriteLine("get LockedObj1....");
     }
    }
   });
}

多次运行可得下面两种结果：第一个图是未发生死锁的情形，第二个图是发生死锁的情形。

8 不要调用Thread.Abort方法。

Task没有提供Abort方法，使用新的TPL（.NET 4.0以后），不会想到这个问题，一般使用CancellationToken来控制取消任务。

9 确保共享变量是安全的

反复运行，可观察到不一样的结果，下图所示。

public static void Func()
{
   string s = "ASDFGH";
   Parallel.Invoke(
    () => { s = s.Replace("A", "1"); s = s.Replace("S", "1s"); },
    () => { s = s.Replace("A", "2"); s = s.Replace("S", "2s"); },
    () => { s = s.Replace("A", "3"); });
   Console.WriteLine(s);
}

10 处理器超额申请与申请不足

public static void Func()
{
   ParallelOptions po = new ParallelOptions();
   //超额申请，处理器只有4个逻辑内核，结果设置并行度为10且是个逻辑内核均在工作，等待的任务数量大于0.
   po.MaxDegreeOfParallelism = 10;
   //申请不足，处理器有4个逻辑内核，却指定并行度为3，还有一个空闲的内核没有被占用(也有可能被其他线程占用，这里假设在指定并行度为3的情况下，另一个内核空闲)
   po.MaxDegreeOfParallelism = 3;
   List<int> list = new List<int>();
   Parallel.ForEach(list, po, m =>
   {
    //业务
   });
}

以上就是本文的全部内容，希望本文的内容对大家的学习或者工作能带来一定的帮助，同时也希望多多支持我们！

ASP.NET：一段比较经典的多线程学习代码

一段比较经典的多线程学习代码. 1.用到了多线程的同步问题. 2.用到了多线程的顺序问题. 如果有兴趣的请仔细阅读下面的代码.注意其中代码段的顺序,思考一下,这些代码的顺序能否互相调换,为什么?这应该对学习很有帮助的.为了演示,让所有的线程都Sleep了一段时间. using System.Net;using System;using System.IO;using System.Text;using System.Threading;using System.Diagnostics; name
.NET Framework中定时器timer的单线程与多线程使用讲解

如果你需要使用规律的时间间隔重复执行一些方法,最简单的方式是使用定时器(timer).与下边的例子相比,定时器可以便捷.高效地使用内存和资源: new Thread (delegate() { while (enabled) { DoSomeAction(); Thread.Sleep (TimeSpan.FromHours (24)); } }).Start(); 这不仅仅会永久占用一个线程,而且如果没有额外的代码,DoSomeAction每天都会发生在更晚的时间.定时器解决了这些问题. .N
.net面向对象之多线程(Multithreading)及多线程高级应用

在.net面向对象程序设计阶段在线程资源共享中的线程安全和线程冲突的解决方案:多线程同步,使用线程锁和线程通知实现线程同步,具体内容介绍如下: 1. ThreadStatic特性特性:[ThreadStatic] 功能:指定静态字段在不同线程中拥有不同的值在此之前,我们先看一个多线程的示例: 我们定义一个静态字段: static int num = 0; 然后创建两个线程进行分别累加: new Thread(() => { for (int i = 0; i < 1000000; i++
asp.net 计划任务管理程序实现，多线程任务加载

asp.net下实现可以将计划任务的方法放在global里,使用一个统一的任务管理类来管理各种任务的执行,做到并行不悖! 下面是我写的一个方法,希望起个抛砖引玉的作用!大家一起学习下: 第一步定义一个接口,用来规范任务必须要实现的动作,该接口只有一个方法(简单起见): 复制代码代码如下: /// <summary> /// 工作单元接口,定义一个计划任务必须完成的工作 /// </summary> public interface IScheduledTask { /// <
.NET Windows 多线程thread编程

进程:工厂搬砖头,10个工人搬完1000个砖头线程:每个工人,搬完100个砖头,就是一个任务采用线程,异步搬: 手工去搬,10个工人同时搬,效率高,异步执行,如果不采用线程,等第一个人搬完后第二个人才搬,那就慢了什么时候不能用线程: 如果要用小车来搬,只有一个小车,那么,在这样的情况下,就不应该用线程,因为只有一个小车,各个线程都在争夺和等待这个小车,所以不能用线程.如果这个时候还要用线程,则导致资源浪费, 因为每个线程都有自己的资源,如包工头(CPU)同一时间要管理这10个工人,而只有一
一些.NET对多线程异常处理技巧分享

多线程环境在我们的产品 SE 中,出现多线程的地方主要有两大类,一类是通过 ThreadPool 或 new Thread 主动发起多线程,另一类是 Socket 通讯回调. 多线程异常捕获对于一般的异常处理来说,我们只要简单的将可能出错的语句包含在 try/catch 语句中即可.我也曾经简单的将该方法运用于多线程的异常捕获,结果并非如此,代码如下: 复制代码代码如下: public static void Main() { try { new Threa
C#(asp.net)多线程用法示例(可用于同时处理多个任务)

本文实例讲述了C#(asp.net)多线程用法.分享给大家供大家参考,具体如下: using System; using System.Collections.Generic; using System.Linq; using System.Web; using System.Web.UI; using System.Threading; using System.Web.UI.WebControls; public partial class muti_thread : System.Web.
c#.net多线程编程教学——线程同步

随着对多线程学习的深入,你可能觉得需要了解一些有关线程共享资源的问题. .NET framework提供了很多的类和数据类型来控制对共享资源的访问. 考虑一种我们经常遇到的情况:有一些全局变量和共享的类变量,我们需要从不同的线程来更新它们,可以通过使用System.Threading.Interlocked类完成这样的任务,它提供了原子的,非模块化的整数更新操作. 还有你可以使用System.Threading.Monitor类锁定对象的方法的一段代码,使其暂时不能被别的线程访问. System
使用.Net实现多线程经验总结

1.简述一般一个程序一个进程,代码是存在进程中的,进程本身不执行代码, 执行代码的是线程. 一般一个进程里就一个线程.(一个商店就一个老板娘.) 进程就是在内存中开辟了一个空间.代码,图片..等就存在这个空间里.代码线程去执行. 默认只有一个线程. 复制代码代码如下: systerm.threading //线程操作的类在这个命名空间下. 2.前台线程与后台线程. 开启一个线程,就是创建一个线程对象即可. 线程默认情况下都是前台线程. 要把所有的前台线程执行完后,程序才会退出. 进程里默认的
android编程之多线程编程实例分析

本文实例讲述了android编程之多线程编程实现方法.分享给大家供大家参考.具体分析如下: 该功能与前面<android开发socket编程之udp发送实例分析>中一样,当按下键后,发送文本框中数据给PC.不同的是把发送数据的功能放在一个线程socket_send中. 一.环境: win7 + eclipse + ndk 二.代码: 主类test_socket.java package test.soket; //import com.test_button.R; import java.io
PHP多线程编程之管道通信实例分析

本文实例讲述了PHP多线程编程之管道通信用法.分享给大家供大家参考.具体分析如下: 一个线程如果是个人英雄主义,那么多线程就是集体主义,你不再是一个独行侠,而是一个指挥家. 管道通信: 1. 管道可以认为是一个队列,不同的线程都可以往里面写东西,也都可以从里面读东西.写就是在队列末尾添加,读就是在队头删除. 2. 管道一般有大小,默认一般是4K,也就是内容超过4K了,你就只能读,不能往里面写了. 3. 默认情况下,管道写入以后,就会被阻止,直到读取他的程序读取把数据读完.而读取线程也会
Java多线程编程中synchronized线程同步的教程

0.关于线程同步 (1)为什么需要同步多线程? 线程的同步是指让多个运行的线程在一起良好地协作,达到让多线程按要求合理地占用释放资源.我们采用Java中的同步代码块和同步方法达到这样的目的.比如这样的解决多线程无固定序执行的问题: public class TwoThreadTest { public static void main(String[] args) { Thread th1= new MyThread1(); Thread th2= new MyThread2(); th1.st
Java多线程编程中synchronized关键字的基础用法讲解

多线程编程中,最关键.最关心的问题应该就是同步问题,这是一个难点,也是核心. 从jdk最早的版本的synchronized.volatile,到jdk 1.5中提供的java.util.concurrent.locks包中的Lock接口(实现有ReadLock,WriteLock,ReentrantLock),多线程的实现也是一步步走向成熟化. 同步,它是通过什么机制来控制的呢?第一反应就是锁,这个在学习操作系统与数据库的时候,应该都已经接触到了.在Java的多线程程序中,当多个程序竞争同一
VC多线程编程详解

本文实例讲述了VC多线程编程概念与技巧,分享给大家供大家参考.具体分析如下: 一.多线程编程要点线程是进程的一条执行路径,它包含独立的堆栈和CPU寄存器状态,每个线程共享所有的进程资源,包括打开的文件.信号标识及动态分配的内存等.一个进程内的所有线程使用同一个地址空间,而这些线程的执行由系统调度程序控制,调度程序决定哪个线程可执行以及什么时候执行线程.线程有优先级别,优先权较低的线程必须等到优先权较高的线程执行完后再执行.在多处理器的机器上,调度程序可将多个线程放到不同的处理器上去运行,这样可
java多线程编程实例

一.相关知识: Java多线程程序设计到的知识: (一)对同一个数量进行操作 (二)对同一个对象进行操作 (三)回调方法使用 (四)线程同步,死锁问题 (五)线程通信等等二．示例一:三个售票窗口同时出售20张票; 程序分析: 1.票数要使用同一个静态值 2.为保证不会出现卖出同一个票数,要java多线程同步锁. 设计思路: 1.创建一个站台类Station,继承Thread,重写run方法,在run方法里面执行售票操作!售票要使用同步锁:即有一个站台卖这张票时,其他站台要等这张票卖完! 2.
java多线程编程同步器Future和FutureTask解析及代码示例

publicinterfaceFuture<V>Future表示异步计算的结果.它提供了检查计算是否完成的方法,以等待计算的完成,并获取计算的结果.计算完成后只能使用get方法来获取结果,如有必要,计算完成前可以阻塞此方法.取消则由cancel方法来执行.还提供了其他方法,以确定任务是正常完成还是被取消了.一旦计算完成,就不能再取消计算.如果为了可取消性而使用Future但又不提供可用的结果,则可以声明Future<?>形式类型.并返回null作为底层任务的结果. Future主要
Java多线程编程实战之模拟大量数据同步

背景最近对于 Java 多线程做了一段时间的学习,笔者一直认为,学习东西就是要应用到实际的业务需求中的.否则要么无法深入理解,要么硬生生地套用技术只是达到炫技的效果. 不过笔者仍旧认为自己对于多线程掌握不够熟练,不敢轻易应用到生产代码中.这就按照平时工作中遇到的实际问题,脑补了一个很可能存在的业务场景: 已知某公司管理着 1000 个微信服务号,每个服务号有 1w ~ 50w 粉丝不等.假设该公司每天都需要将所有微信服务号的粉丝数据通过调用微信 API 的方式更新到本地数据库. 需求分析对此
Java学习随记之多线程编程

Process和Thread 程序是指令和数据的有序集合, 本身没有运行的含义,是一个静态的概念. 进程是执行程序的一次执行过程,他是一个动态的概念,是系统资源分配的单位一个进程中可以包含若干个线程,线程是CPU调度和执行的单位线程创建三种创建方法继承Thread类 //创建线程方法一:继承Thread类,重写run() 方法,调用start开启主线程 public class TestThread01 extends Thread{ @Override public void run(
linux下c语言的多线程编程

我们在写linux的服务的时候,经常会用到linux的多线程技术以提高程序性能多线程的一些小知识: 一个应用程序可以启动若干个线程. 线程(Lightweight Process,LWP),是程序执行的最小单元. 一般一个最简单的程序最少会有一个线程,就是程序本身,也就是主函数(单线程的进程可以简单的认为只有一个线程的进程) 一个线程阻塞并不会影响到另外一个线程. 多线程的进程可以尽可能的利用系统CPU资源. 1创建线程先上一段在一个进程中创建一个线程的简单的代码,然后慢慢深入. #incl

.Net多线程编程（误用点分析）

相关推荐

随机推荐