0

Пытаюсь реализовать мнопоточный расчет интеграла методами левых прямоугольников и трапеций. Но при увеличении кол-ва потоков время работы программы уменьшается примерно на 4-5к мс, что несущественно. Переменная check нужна для определения каким методом считать интеграл. Каждому потоку передает значение number и прогоняю цикл от number до i += кол-во потоков, конфликт потоков возникать не должен.

using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Windows.Forms;
using System.Diagnostics;
using System.Threading;

namespace PotokIntegral
{
    public partial class Form1 : Form
    {
        public Form1()
        {
            InitializeComponent();
        }
        static int check = 0;
        static double bi = 0;
        static double biMetod = 0;
        static double xi = 0;
        static double a = 0;
        static double b = 2;
        static double N = 0;
        static double h = 0;
        static double F = 0;
        static double Fpred = 0;
        static double Fb = 0.5 * Math.Atan(2 / 2);
        static double Fa = 0;
        static double[] sum1 = new double [100];
        static double[] sum2 = new double [100];
        static double sumItog = 0;
        static double metodPr = 0;
        static double metodTrap = 0;
        static double Fitog = Fb - Fa;
        static int numberPotoks = 0;
        private void button1_Click(object sender, EventArgs e)
        {
            sumItog = 0; bi = 0; xi = 0;
            Array.Clear(sum1, 0, 100);
            Array.Clear(sum2, 0, 100);
            if (radioButton1.Checked == true)
            {
                check = 1;
            }
            else
            {
                check = 2;
            }

            N = int.Parse(numericUpDown1.Value.ToString()); //число разбиений
            numberPotoks = int.Parse(numericUpDown2.Value.ToString()); //число потоков
            h = (b - a) / N;

            Thread[] th = new Thread[numberPotoks];
            Stopwatch s = new Stopwatch();
            s.Start();
            for (int i = 0; i < numberPotoks; i++)
            {
                th[i] = new Thread(method);
                th[i].Start(i);
            }
            for (int i = 0; i < numberPotoks; i++)
            {
                th[i].Join();
            }
            s.Stop();
            if (check == 1)
                for (int i = 0; i < numberPotoks; i++)
                {
                    sumItog += sum1[i];
                }
            if (check == 2)
                for (int i = 0; i < numberPotoks; i++)
                {
                    sumItog += sum2[i];
                }

            richTextBox1.Text += "Кол-во потоков: "+numberPotoks.ToString()+" Значение интеграла: " + Math.Round(sumItog, 5).ToString() +
            " Время работы потоков: " + s.ElapsedMilliseconds.ToString() + "\r\n";
        }

        private void method(object number)
        {
            if (check == 1)
            {
                for (int i = (int)number; i < N; i += numberPotoks)
                {
                    Fpred = 1 / (xi*xi + 4);
                    sum1[(int)number] += Fpred * h;
                    xi += h;
                }
            }
            else if (check == 2)
            {
                for (int i = (int)number; i < N; i += numberPotoks)
                {
                    biMetod = xi + h;
                    Fpred = 1 / (xi*xi + 4);
                    F = 1 / (biMetod*biMetod + 4);
                    metodTrap = ((Fpred + F) / 2) * h;
                    sum2[(int)number] += metodTrap;
                    bi = xi + h;
                    xi = bi;
                }
            }
        }
    }
}

В чем может быть проблема?

5
  • bi = xi + h; xi = bi; - в потоке? Переделать!
    – user176262
    6 апр 2018 в 12:32
  • @Igor xi += h; для второго условия забыл переписать
    – Hedgehog
    6 апр 2018 в 12:40
  • Это все равно. У Вас потоки используют одни и те же переменные. Тут не может получиться правильный результат. Замените все статические переменные на локальные.
    – user176262
    6 апр 2018 в 12:44
  • @igor заменил, на время работы это никак не повлияло
    – Hedgehog
    6 апр 2018 в 12:53
  • 2
    Какой смысл говорить о быстродействии неправильного кода?
    – user176262
    6 апр 2018 в 13:14

1 ответ 1

1
using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Windows.Forms;
using System.Diagnostics;
using System.Threading;

namespace Lab5
{
    public partial class Form1 : Form
    {
        public Form1()
        {
            InitializeComponent();
        }
        double a;
        double b;
        double[] sum;
        double N;
        int numberPotoks;
        private void button1_Click(object sender, EventArgs e)
        {
            numberPotoks = int.Parse(numericUpDown2.Value.ToString()); //число потоков
            Thread[] th = new Thread[numberPotoks];
            Stopwatch s = new Stopwatch();
            sum = new double[numberPotoks];
            N = (long)(numericUpDown1.Value); //число разбиений
            a = 0;
            b = 2;
            s.Start();
            for (int i = 0; i < numberPotoks; i++)
            {
                th[i] = new Thread(method);
                th[i].Start(i);
            }
            for (int i = 0; i < numberPotoks; i++)
            {
                th[i].Join();
            }
            s.Stop();
            double sumItog = 0;
            for (int i = 0; i < numberPotoks; i++)
            {
                sumItog += sum[i];
            }
            double etalon =  0.5 * Math.Atan(2 / 2);
            richTextBox1.Text += "Кол-во потоков: "+numberPotoks.ToString()+" Значение интеграла: " + Math.Round(sumItog, 5).ToString() +
            " Время работы потоков: " + s.ElapsedMilliseconds.ToString() + "\r\n";
        }

        private void method(object number)
        {
            double F, xi, S = 0, h = (b - a) / N;
            if (radioButton1.Checked)
            {
                for (int i = (int)number; i < N; i += numberPotoks)
                {
                    xi = a + i *h;
                    F = 1 / (xi*xi + 4);
                    S += F * h;
                }
                sum[(int)number] = S;
            }
            else
            {
                for (int i = (int)number; i < N; i += numberPotoks)
                {
                    xi = a + i * h;
                    S += (((1 / ((xi + h) * (xi + h) + 4)) + 1 / (xi * xi + 4)) / 2) * h;
                }
                sum[(int)number] = S;
            }
        }
    }
}

Ваш ответ

By clicking “Отправить ответ”, you agree to our terms of service and acknowledge you have read our privacy policy.

Всё ещё ищете ответ? Посмотрите другие вопросы с метками или задайте свой вопрос.