C# 线程--第四线程实例

概述

在前面几节中和大家分享了线程的一些基础使用方法,本章结合之前的分享来编写一些日常开发中应用实例,和编写多线程时一些注意点。如大家有好的实例也欢迎分享..

应用实例

应用:定时任务程序

场景:系统中常常会有一些需要定时去循环执行的存储过程或方法等,这时就出现了定时任务小程序。

模型:查询需定时执行的计划任务-->插入线程池-->执行任务

static void MainMethod()
{
    Thread thead;

    thead = new Thread(QueryTask);
    thead.IsBackground = true;
    thead.Start();

    Console.Read();
}

/// <summary>
/// 查询计划任务
/// </summary>
static void QueryTask()
{
    TaskModel todo_taskModel;
    while (true)
    {
        int count = new Random().Next(1, 10);    //模拟产生任务记录数
        for (int i = 0; i < count; i++)
        {
            todo_taskModel = new TaskModel() { TaskID = i, ITime = DateTime.Now };
            ThreadPool.QueueUserWorkItem(InvokeThreadMethod, todo_taskModel);
        }

        Thread.Sleep(30000);    //30s循环一次
    }
}

/// <summary>
/// 完成计划任务
/// </summary>
/// <param name="taskModel"></param>
static void InvokeThreadMethod(object taskModel)
{
    TaskModel model = (TaskModel)taskModel;

    Console.WriteLine("执行任务ID:{0}......执行完成.{1}", model.TaskID, model.ITime);
}

/// <summary>
/// 任务实体
/// </summary>
class TaskModel
{
    public int TaskID { get; set; }
    public DateTime ITime { get; set; }
}

1.查询计划任务时只管有任务就推给线程池,不等待线程池中任务是否完成.(避免有些计划任务耗时比较长,阻塞后面定时任务执行时间)每隔30秒循环一次计划任务.

2.每条计划任务完成后打印相应信息.(也可记录日志)

3.如果查询计划任务记录数较多,可调整相应的循环时间间隔。避免任务插入线程池时间过长阻塞后面定时任务执行时间。

应用:数据推送程序

场景:在我们日常系统中会存在很多接口数据需要实时推送给第三方平台(如:会员信息发生变化推送给微信平台..)。这时我们就需写一些数据推送程序。

模型:检索任务-->插入线程池-->等待线程池任务完成-->提示任务完成

static void MainMethodB()
{
    Thread thread = new Thread(QueryTaskB);
    thread.IsBackground = true;
    thread.Start();
}
static void QueryTaskB()
{
    ManualResetEvent[] manualReset;
    TaskModeB model;

    while (true)
    {
        int RandomNumber = new Random().Next(0, 6);
        manualReset = new ManualResetEvent[RandomNumber];
        for (int i = 0; i < RandomNumber; i++)
        {
            manualReset[i] = new ManualResetEvent(false);
            model = new TaskModeB() { TaskId = i, ITime = DateTime.Now, manualResetEvent = manualReset[i] };
            ThreadPool.QueueUserWorkItem(InvokeThreadMethodB, model);
        }

        //等待线程池任务完成
        ManualResetEvent.WaitAll(manualReset);
        Console.WriteLine("线程池任务已完成.完成时间:{0}",DateTime.Now);

        Thread.Sleep(30000);
    }
}

static void InvokeThreadMethodB(object obj)
{
    TaskModeB model = (TaskModeB)obj;
    Thread.Sleep(1000);
    Console.WriteLine("执行任务ID:{0},执行时间:{1},完成时间:{2}", model.TaskId, model.ITime, DateTime.Now);
    model.manualResetEvent.Set();
}

class TaskModeB
{
    public int TaskId { set; get; }
    public DateTime ITime { set; get; }
    public ManualResetEvent manualResetEvent { set; get; }
}

QueryTaskB()在检索任务记录数后会记录任务条数,并实例化对应的ManualResetEvent数组,做为参数传给线程池中线程任务。

最后等待线程池中所有任务执行完成。后续可根据实际需要编写各自业务逻辑。

两个实例的不同点:是否等待线程池中的所有任务完成。

实例1中定时任务对执行的时间要求比较高,到了某个时间点必须执行某个任务。所以不能等待线程池中的任务完成。

缺点:有任务就插入线程池,有些任务可能会执行很久,线程池每隔30秒循环一次,最后会导致线程池中有存在很多耗时很长的任务在线程池中未执行完。当线程池中线程数达到1023(线程池默认最大线程数)后线程池就不会在创建新的线程数去完成新的任务,只能等待当前线程池中线程数得到释放。

实例2中数据推送程序对推送的时间要求相对1中要低一点。接口表中只要检索到数据就推送给第三方平台。一般每次传输数据量不是很多,但很频繁。

缺点:当推送数据量大时,执行任务时间可能会较长。主线程会等待线程池中的所有任务完成。所有每次循环检索任务的时间间隔可能会出现30S+NS现象。

时间: 2024-11-07 12:21:35

C# 线程--第四线程实例的相关文章

Java多线程(四) 线程池

一个优秀的软件不会随意的创建很销毁线程,因为创建和销毁线程需要耗费大量的CPU时间以及需要和内存做出大量的交互.因此JDK5提出了使用线程池,让程序员把更多的精力放在业务逻辑上面,弱化对线程的开闭管理. JDK提供了四种不同的线程池给程序员使用 首先使用线程池,需要用到ExecutorService接口,该接口有个抽象类AbstractExecutorService对其进行了实现,ThreadPoolExecutor进一步对抽象类进行了实现.最后JDK封装了一个Executor类对ThreadP

C++11线程指南(四)--右值引用与移动语义

1. 按值传递 什么是按值传递? 当一个函数通过值的方式获取它的参数时,就会包含一个拷贝的动作.编译器知道如何去进行拷贝.如果参数是自定义类型,则我们还需要提供拷贝构造函数,或者赋值运算符来进行深拷贝.然而,拷贝是需要代价的.在我们使用STL容器时,就存在大量的拷贝代价.当按值传递参数时,会产生临时对象,浪费宝贵的CPU以及内存资源. 需要找到一个减少不必要拷贝的方法.移动语义就是其中一种. 2. 右值引用 此处介绍右值引用的目的,是为了实现后面的移动语义. 右值引用使得我们可以分辨一个值是左值

C# 线程(四):生产者和消费者

From : http://kb.cnblogs.com/page/42530/ 前面说过,每个线程都有自己的资源,但是代码区是共享的,即每个线程都可以执行相同的函数.这可能带来的问题就是几个线程同时执行一个函数,导致数据的混乱,产生不可预料的结果,因此我们必须避免这种情况的发生. C#提供了一个关键字lock,它可以把一段代码定义为互斥段(critical section),互斥段在一个时刻内只允许一个线程进入执行,而其他线程必须等待.在C#中,关键字lock定义如下: lock(expres

C#中的线程(四)高级话题

C#中的线程(四)高级话题 Keywords:C# 线程Source:http://www.albahari.com/threading/Author: Joe AlbahariTranslator: Swanky WuPublished: http://www.cnblogs.com/txw1958/Download:http://www.albahari.info/threading/threading.pdf 第四部分:高级话题 非阻止同步 早些时候,我们讨论了非常简单的赋值和 更新一个字

Java多线程(四) —— 线程并发库之Atomic

一.从原子操作开始 从相对简单的Atomic入手(java.util.concurrent是基于Queue的并发包,而Queue,很多情况下使用到了Atomic操作,因此首先从这里开始). 很多情况下我们只是需要一个简单的.高效的.线程安全的递增递减方案.注意,这里有三个条件: 简单,意味着程序员尽可能少的操作底层或者实现起来要比较容易: 高效意味着耗用资源要少,程序处理速度要快: 线程安全也非常重要,这个在多线程下能保证数据的正确性. 这三个条件看起来比较简单,但是实现起来却难以令人满意. 通

windows线程池四种情形(win核心读书笔记)

windows线程池四种情形(win核心读书笔记) Mircosoft从Windows2000引入线程池API,并在Vista后对线程池重新构架,引入新的线程池API.以下所有线程池函数均适用于Vista以后的版本. 用Windows提供的线程池函数有以下几个好处:1,不必要用CreateThread创建线程:2,不必要管理自己线程:3,Windows封装好的线程池,效率高,性能优越. 1 异步方式调用函数 这种方式和我们用CreateThread创建线程的用法差不多,给定一个线程函数模板实现功

Java 并发编程(三)设计线程安全的类-实例封闭

到目前为止,我们已经介绍了关于线程安全与同步的一些基础知识.然而,我们并不希望对每一次内存访问都进行分析以确保是线程安全的,而是希望将一些现有的线程安全组件组合为更大规模的组合为更大规模的组件或程序.之后,我们会讲一些设计线程安全类的一些基本概念,介绍一些组合模式. 一.设计线程安全的类 在设计线程安全类的过程中,需要包含以下三个基本要素: 1.找出构成对象状态的所有变量 2.找出约束状态变量的不变性条件 3.建立对象状态的并发访问管理策略 要分析对象的状态,首先从对象的域开始.如果对象中所有的

java多线程 同步方法也会被抢, 就是只有同步方法在其他线程要访问同一个实例的同步方法时。。。。

ackage cn.twj.rtti.t;//: concurrency/AtomicityTest.java import java.util.concurrent.*; public class AtomicityTest implements Runnable { private int i = 0; public int getValue() { return i; } //设置此方法为同步方法的意思并不是说进入此方法后其他线程就会等待此方法完成了 //在非进入此方法的线程中,还是会和当

Java多线程(4)----线程的四种状态

与人有生老病死一样,线程也同样要经历开始(等待).运行.挂起和停止四种不同的状态.这四种状态都可以通过Thread类中的方法进行控制.下面给出了Thread类中和这四种状态相关的方法. 1 // 开始线程 2 public void start( ); 3 public void run( ); 4 5 // 挂起和唤醒线程 6 public void resume( ); // 不建议使用 7 public void suspend( ); // 不建议使用 8 public static v