zoukankan      html  css  js  c++  java
  • c# 线程池:开启10个线程运行Fibonacci,并在所有线程运行完后,得出结果。

    namespace CAThreadPool
    {
        class ThreadpoolDemo6
        {
            static void Main(string[] args)
            {
                const int FibonacciCalculations = 10;
    
                // One event is used for each Fibonacci object.
                ManualResetEvent[] doneEvents = new ManualResetEvent[FibonacciCalculations];
                Fibonacci[] fibArray = new Fibonacci[FibonacciCalculations];
                Random r = new Random();
    
                // Configure and start threads using ThreadPool.
                Console.WriteLine("launching {0} tasks...", FibonacciCalculations);
                for (int i = 0; i < FibonacciCalculations; i++)
                {
                    doneEvents[i] = new ManualResetEvent(false);
                    Fibonacci f = new Fibonacci(r.Next(20, 40), doneEvents[i]);
                    fibArray[i] = f;
                    ThreadPool.QueueUserWorkItem(f.ThreadPoolCallback, i);
                }
    
                // Wait for all threads in pool to calculate.
                WaitHandle.WaitAll(doneEvents);
                Console.WriteLine("All calculations are complete.");
    
                // Display the results. 
                for (int i = 0; i < FibonacciCalculations; i++)
                {
                    Fibonacci f = fibArray[i];
                    Console.WriteLine("Fibonacci({0}) = {1}", f.N, f.FibOfN);
                }
                Console.ReadKey();
            }
        }
        public class Fibonacci
        {
            private int _n;
            private int _fibOfN;
            private ManualResetEvent _doneEvent;
    
            public int N { get { return _n; } }
            public int FibOfN { get { return _fibOfN; } }
            // Constructor. 
            public Fibonacci(int n, ManualResetEvent doneEvent)
            {
                _n = n;
                _doneEvent = doneEvent;
            }
            // Recursive method that calculates the Nth Fibonacci number. 
            public int Calculate(int n)
            {
                if (n <= 1)
                {
                    return n;
                }
                return Calculate(n - 1) + Calculate(n - 2);
            }
            // Wrapper method for use with thread pool. 
            public void ThreadPoolCallback(Object threadContext)
            {
                int threadIndex = (int)threadContext;
                Console.WriteLine("thread {0} started...", threadIndex);
                _fibOfN = Calculate(_n);
                Console.WriteLine("thread {0} result calculated...", threadIndex);
                _doneEvent.Set();
            }
        }
    }
  • 相关阅读:
    Java面試題(实用性高)
    索引的概述?
    给Eclipse提速的7个技巧
    ETL数据仓库
    实用SQL语句大全
    考证
    PL/SQL 程序
    eclipse
    httpd.conf详解,因为php始终报fileinfo扩展无法加载的错
    dockerfile创建镜像及容器
  • 原文地址:https://www.cnblogs.com/25miao/p/10397468.html
Copyright © 2011-2022 走看看