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 that you have read and understand our privacy policy and code of conduct.

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