查询处理器未能为执行并行查询启动必要的线程资源啥意思

Posted 2023-05-07

线程共享的环境包括：进程代码段、进程的公有数据(利用这些共享的数据，线程很容易的实现相互之间的通讯)、进程打开的文件描述符、信号的处理器、进程的当前目录和进程用户ID与进程组ID。

举例：

GPU中渲染流水线相似，流水线都会处理大量的图形渲染，每一条流水线可以同时并行处理任务。 cpu线程就相似于GPU的流水线，每一线程处理多个程序。多核心cpu也就是多线程，程序只要支持多核心处理，就能够将程序利用多线程来进行处。

扩展资料：

线程的实体包括程序、数据和TCB。线程是动态概念，它的动态特性由线程控制块TCB（Thread Control Block）描述。TCB包括以下信息：

（1）线程状态。

（2）当线程不运行时，被保存的现场资源。

（3）一组执行堆栈。

（4）存放每个线程的局部变量主存区。

（5）访问同一个进程中的主存和其它资源。

用于指示被执行指令序列的程序计数器、保留局部变量、少数状态参数和返回地址等的一组寄存器和堆栈。

参考资料来源：百度百科-线程

参考技术A 首先举个例子：GPU中渲染流水线相似，流水线都会处理大量的图形渲染，每一条流水线可以同时并行处理任务。 cpu线程就相似于GPU的流水线，每一线程处理多个程序。多核心cpu也就是多线程，程序只要支持多核心处理，就能够将程序利用多线程来进行处本回答被提问者采纳

并行LINQ PLinq

1、描述

     并行 LINQ (PLINQ) 是 LINQ 模式的并行实现。 PLINQ 查询在许多方面类似于非并行 LINQ to Objects 查询。 PLINQ 尝试充分利用系统中的所有处理器, 它利用所有处理器的方法是，将数据源分成片段，然后在多个处理器上对单独工作线程上的每个片段并行执行查询。 在许多情况下，并行执行意味着查询运行速度显著提高。

PLINQ有两个重要的类:ParallelEnumerable和ParallelQuery.其中, ParallelEnumerable包含许多在ParallelQuery类型上进行操作的扩展方法. ParallelEnumerable同样实现许多在上Enumerable的方法,因为 ParallelQuery 实现IEnumerable接口,使用我们可以很方便的创建ParallelQuery类的一个实例并运用在ParallelEnumerable上实现的并行方法. 做了一简单测试，如下。当数据量大时就能体现出效率差距。

 

2、案例代码以及结果 

 2.1  demoCode

 class Program
    {
        static void Main(string[] args)
        {
            //一般方法
            Test();
           //并行计算方法
            TestAsParallel();
            Console.ReadLine();
        }

        private static void TestAsParallel()
        {
            Console.WriteLine($"并行查询开始");
            var t1 = DateTime.Now;
            
            int[] source = new int[100000000];
            for (int i = 0; i < source.Length; i++)

            {

                source[i] = i;

            }
            var presult = source.AsParallel().Select(c => Math.Pow(c, 3));
           var Tspan=   DateTime.Now.Subtract(t1);
          Console.WriteLine($"并行查询耗时{Tspan.TotalSeconds}秒");
        }
        private static void Test()
        {
            Console.WriteLine($"一般查询开始");
            var t1 = DateTime.Now;
            int[] source = new int[100000000];
            var temp = new double[100000000];
            for (int i = 0; i < source.Length; i++)

            {
                source[i] = i;
            }
            for (int i = 0; i < source.Length; i++)
            {
                temp[i]= Math.Pow(source[i], 3);
            }       
            var Tspan = DateTime.Now.Subtract(t1);
            Console.WriteLine($"一般查询耗时{Tspan.TotalSeconds}秒");
        }

    }

 

 2.2 resultOoutput