RError.com

RError.com Logo RError.com Logo

RError.com Navigation

  • 主页

Mobile menu

Close
  • 主页
  • 系统&网络
    • 热门问题
    • 最新问题
    • 标签
  • Ubuntu
    • 热门问题
    • 最新问题
    • 标签
  • 帮助
主页 / 问题 / 846530
Accepted
Emigrant
Emigrant
Asked:2020-06-25 22:06:29 +0000 UTC2020-06-25 22:06:29 +0000 UTC 2020-06-25 22:06:29 +0000 UTC

TPL 中的信号量

  • 772

在我的程序中,只有一定数量的线程才能访问函数。有以下代码:

int totalTasksExecute = 3, currentTasksExecute = 0;
Task[] tasks = new Task[totalTasksExecute];
foreach(ObjModel obj in Objs)
{
    if (currentTasksExecute == totalTasksExecute)
    {
        Task.WaitAll(tasks);
        currentTasksExecute = 0;
    }
    Thread.Sleep(500);
    tasks[currentTasksExecute++] = Task.Factory.StartNew(() => GetWebInfo(obj));
}
Task.WaitAll(tasks);

由于它发生了好几次,我决定将它作为一个单独的类发布。在一个类中,我使用 Semaphore 来限制同时访问一个函数。

public class MultiTasks<T>
{
    private readonly Action<T> _callback;
    private readonly Semaphore semaphore;
    private readonly List<T> ts;
    private readonly AutoResetEvent[] waitHandles;

    private int Count;

    public MultiTasks(Action<T> callback, int maxRunTasks, List<T> objListForTask)
    {
        ts = objListForTask;
        _callback = callback;
        semaphore = new Semaphore(maxRunTasks, maxRunTasks);
        waitHandles = new AutoResetEvent[objListForTask.Count];
        for (int i = 0; i < waitHandles.Length; i++)
            waitHandles[i] = new AutoResetEvent(false);
    }
    public void Start(int waitMilliSeconds)
    {
        Count = 0;
        foreach(T obj in ts)
            Task.Factory.StartNew(() =>
            {
                semaphore.WaitOne();
                _callback(obj);
                waitHandles[Count].Set();
                Interlocked.Increment(ref Count);
                Thread.Sleep(waitMilliSeconds);
                semaphore.Release();
            });
        WaitHandle.WaitAll(waitHandles);
    }
}

我这样称呼:

MultiTasks<ObjModel> multiTasks = 
   new MultiTasks<ObjModel>(GetWebInfo, 3, objs.ToList());
multiTasks.Start(500);

问题是,在第一种情况下,处理时间大约需要 30 秒,在第二种情况下要长 2 倍。也许这个类没有正确实现?或者我没有正确使用信号量?

c#
  • 1 1 个回答
  • 10 Views

1 个回答

  • Voted
  1. Best Answer
    tym32167
    2020-06-25T22:27:39Z2020-06-25T22:27:39Z

    如果您正在做一些应该并行运行的事情,但同时不超过 N 个线程,那么使用现成的设计是否有意义?举个例子:

    int i = 0;
    Enumerable.Range(1, 100).AsParallel().WithDegreeOfParallelism(3).ForAll(x =>
    {
        Interlocked.Increment(ref i);
        Console.WriteLine($"Processing {x} - threads there - {i}");
        Interlocked.Decrement(ref i);
    });
    

    输出将类似于

    Processing 1 - threads there - 1
    Processing 2 - threads there - 1
    Processing 4 - threads there - 3
    Processing 6 - threads there - 3
    Processing 7 - threads there - 3
    Processing 8 - threads there - 3
    Processing 9 - threads there - 3
    .........
    Processing 93 - threads there - 3
    Processing 94 - threads there - 3
    Processing 95 - threads there - 3
    Processing 96 - threads there - 3
    Processing 97 - threads there - 3
    Processing 98 - threads there - 3
    Processing 99 - threads there - 3
    Processing 100 - threads there - 3
    Processing 19 - threads there - 3
    Processing 20 - threads there - 2
    Processing 5 - threads there - 3
    

    也就是说,不超过 3 个同时运行的线程。

    • 4

相关问题

Sidebar

Stats

  • 问题 10021
  • Answers 30001
  • 最佳答案 8000
  • 用户 6900
  • 常问
  • 回答
  • Marko Smith

    是否可以在 C++ 中继承类 <---> 结构?

    • 2 个回答
  • Marko Smith

    这种神经网络架构适合文本分类吗?

    • 1 个回答
  • Marko Smith

    为什么分配的工作方式不同?

    • 3 个回答
  • Marko Smith

    控制台中的光标坐标

    • 1 个回答
  • Marko Smith

    如何在 C++ 中删除类的实例?

    • 4 个回答
  • Marko Smith

    点是否属于线段的问题

    • 2 个回答
  • Marko Smith

    json结构错误

    • 1 个回答
  • Marko Smith

    ServiceWorker 中的“获取”事件

    • 1 个回答
  • Marko Smith

    c ++控制台应用程序exe文件[重复]

    • 1 个回答
  • Marko Smith

    按多列从sql表中选择

    • 1 个回答
  • Martin Hope
    Alexandr_TT 圣诞树动画 2020-12-23 00:38:08 +0000 UTC
  • Martin Hope
    Suvitruf - Andrei Apanasik 什么是空? 2020-08-21 01:48:09 +0000 UTC
  • Martin Hope
    Air 究竟是什么标识了网站访问者? 2020-11-03 15:49:20 +0000 UTC
  • Martin Hope
    Qwertiy 号码显示 9223372036854775807 2020-07-11 18:16:49 +0000 UTC
  • Martin Hope
    user216109 如何为黑客设下陷阱,或充分击退攻击? 2020-05-10 02:22:52 +0000 UTC
  • Martin Hope
    Qwertiy 并变成3个无穷大 2020-11-06 07:15:57 +0000 UTC
  • Martin Hope
    koks_rs 什么是样板代码? 2020-10-27 15:43:19 +0000 UTC
  • Martin Hope
    Sirop4ik 向 git 提交发布的正确方法是什么? 2020-10-05 00:02:00 +0000 UTC
  • Martin Hope
    faoxis 为什么在这么多示例中函数都称为 foo? 2020-08-15 04:42:49 +0000 UTC
  • Martin Hope
    Pavel Mayorov 如何从事件或回调函数中返回值?或者至少等他们完成。 2020-08-11 16:49:28 +0000 UTC

热门标签

javascript python java php c# c++ html android jquery mysql

Explore

  • 主页
  • 问题
    • 热门问题
    • 最新问题
  • 标签
  • 帮助

Footer

RError.com

关于我们

  • 关于我们
  • 联系我们

Legal Stuff

  • Privacy Policy

帮助

© 2023 RError.com All Rights Reserve   沪ICP备12040472号-5