• Najnowsze pytania
  • Bez odpowiedzi
  • Zadaj pytanie
  • Kategorie
  • Tagi
  • Zdobyte punkty
  • Ekipa ninja
  • IRC
  • FAQ
  • Regulamin
  • Książki warte uwagi

[C++\CLI] Poprawne anulowanie "Task^"

Object Storage Arubacloud
+1 głos
303 wizyt
pytanie zadane 13 marca 2016 w C i C++ przez Mateusz Tocha Bywalec (2,560 p.)

Cześć 

Próbuje swoich sił w programowani wielowątkowych, jako że background worker nie bardzo odpowiada mi moim potrzebom postanowiłem zostać przy Task^.

Jednak pojawia się problem w jaki sposób go anulować, dokumentacja MSDN pokazuje jak to zrobić z tak zwanym CancellationToken, no ale niestety nie mogę sobie poradzić.

MyForm.h

#pragma once

namespace Task_Factory {

	using namespace System;
	using namespace System::ComponentModel;
	using namespace System::Collections;
	using namespace System::Windows::Forms;
	using namespace System::Data;
	using namespace System::Drawing;
	using namespace System::Threading::Tasks;
	using namespace System::Threading;
	
	public ref class MyForm : public System::Windows::Forms::Form
	{
	public:
		MyForm(void);	
		Task^ taskFact;
		void DoSomeWork(CancellationToken t);
		void updateProgress(int i);
	protected:		
		~MyForm();	
	private:		
		delegate void updateUIdelegate(int i);
		void updateUI(int i);
		System::ComponentModel::Container ^components;
		void button1_Click(System::Object^  sender, System::EventArgs^  e);
		void button2_Click(System::Object^  sender, System::EventArgs^  e);
		System::Windows::Forms::Button^  btnStart;
		System::Windows::Forms::Button^  btnStop;
		System::Windows::Forms::ProgressBar^  progressBar1;
		System::Windows::Forms::Label^  label1;
		CancellationTokenSource^ source;		

#pragma region Windows Form Designer generated code
		void InitializeComponent(void);
#pragma endregion	
	};
}

MyForm.Cpp

 

#pragma once
#include "MyForm.h"

namespace Task_Factory {


	MyForm::MyForm(void) {
		InitializeComponent();		
		this->source= gcnew CancellationTokenSource();
		
	}

	void MyForm::DoSomeWork() {
		
		Progress<int>^ progressHandler = gcnew Progress<int>(gcnew Action<int>(this, &MyForm::updateProgress));
		
		IProgress<int>^ progress = safe_cast<IProgress<int>^>(progressHandler);
		
		for (size_t i = 0; i < 100; i++)
		{
			progress->Report(i);
			System::Threading::Thread::Sleep(1000);
		}

	}

	void MyForm::updateProgress(int i) {
		updateUIdelegate^ UIaction = gcnew updateUIdelegate(this, &MyForm::updateUI);
		this->BeginInvoke(UIaction, i);
	}

	void MyForm::updateUI(int i) {
		this->label1->Text = i+"%";
		this->progressBar1->Value = i;
	}

	void MyForm::button1_Click(System::Object^  sender, System::EventArgs^  e) {

		this->taskFact = Task::Factory->StartNew(gcnew Action(this, &MyForm::DoSomeWork), this->source->Token);
		
	}

	void MyForm::button2_Click(System::Object^  sender, System::EventArgs^  e) {
		this->source->Cancel();
	}

	MyForm::~MyForm() {
		if (components) {
			delete components;
		}
	}
	void MyForm::InitializeComponent(void) {
		(...)
	}
}

W momencie wciśnięcia klawisza start(button1) rozpoczyna się nowy wątek, wypełniający pasek postępu, w tym momencie możliwe jest poruszanie okienkiem, bez zadnych zwiek itp,

W momencie wciśnięcia Stop Token powinnien wyzwolić sygnał Cancel(), 

 

Próbowałem wielu rzeczy jeżeli linie 

this->source->Cancel();

wkleje do funkcji obsługi zdarzenie klawisza start:

this->taskFact = Task::Factory->StartNew(gcnew Action(this, &MyForm::DoSomeWork), this->source->Token);
this->source->Cancel();

to wątek się nie rozpoczyna.

 

Chciałbym poprawnie skonfigurować obsługę zdarzenia dla klawisza STOP, w taki sposób aby wątek był przerwany w momencie jego wciśnięcia.

Pozdrawiam

1 odpowiedź

+1 głos
odpowiedź 13 marca 2016 przez Mateusz Tocha Bywalec (2,560 p.)

No niestety z tego co się dowiedziałem na tej stronie https://johnbadams.wordpress.com/2012/03/10/understanding-cancellationtokensource-with-tasks/ to że token jest wyzwalany nie oznacza ze Task zostanie zakończony w tym momencie, co ma prawdopodobnie pewne uzasadnienie. Otóż Task będzie łaskawie poproszony o to żeby zakończyć swój żywot, ale zrobi to dopiero po skończonej pracy. 

 

Poszedłem krok niżej bo do zwykłego Threada no i to niby działa, ale muszę poczytać jakie to będzie miało ograniczenia, no jedno to wiem nie będzie dodawany to tego ThreadPool więc będzie trzeba popatrzeć jak to zrobić ręcznie.

Jeżeli ktoś byłby ciekawy jak to rozwiązałem to prosze:

MyForm.h

namespace Thread_example {

	using namespace System;
	using namespace System::ComponentModel;
	using namespace System::Collections;
	using namespace System::Windows::Forms;
	using namespace System::Data;
	using namespace System::Drawing;
	using namespace System::Threading;
	public ref class MyForm : public System::Windows::Forms::Form
	{
	public:
		MyForm(void);
	protected:		
		~MyForm();
	private:
		delegate void updateUIdelegate(int i);
		void UpdateUI(int i);

		delegate void updateProgresBarDelegate(int i);
		void updateProgressBar(int i);
		

		Thread^ thread;
		void doSomeWork(Object^ obj);
		void MyForm::updateProcess(int i);
		System::Windows::Forms::Button^  button1;
		System::Windows::Forms::Button^  button2;
		System::Windows::Forms::ProgressBar^  progressBar1;
		System::Windows::Forms::Label^  label1;
		System::ComponentModel::Container ^components;		
#pragma region Windows Form Designer generated code
		void button1_Click(System::Object^  sender, System::EventArgs^  e);
		void button2_Click(System::Object^  sender, System::EventArgs^  e);
		void InitializeComponent();		
#pragma endregion			
	};
}

MyForm.cpp

#pragma once
#include "MyForm.h"

namespace Thread_example {

	MyForm::MyForm(void) {
		this->InitializeComponent();
		this->thread = gcnew Thread(gcnew ParameterizedThreadStart(this, &MyForm::doSomeWork));
	}
	MyForm::~MyForm() {
		if (this->thread->ThreadState == ThreadState::Suspended){
			this->thread->Resume();		
		}
		this->thread->Abort();
	}

	void MyForm::InitializeComponent(void)
	{
		this->button1 = (gcnew System::Windows::Forms::Button());
		this->button2 = (gcnew System::Windows::Forms::Button());
		this->progressBar1 = (gcnew System::Windows::Forms::ProgressBar());
		this->label1 = (gcnew System::Windows::Forms::Label());
		this->SuspendLayout();
		// 
		// button1
		// 
		this->button1->Location = System::Drawing::Point(48, 81);
		this->button1->Name = L"button1";
		this->button1->Size = System::Drawing::Size(75, 23);
		this->button1->TabIndex = 0;
		this->button1->Text = L"Start";
		this->button1->UseVisualStyleBackColor = true;
		this->button1->Click += gcnew System::EventHandler(this, &MyForm::button1_Click);
		// 
		// button2
		// 
		this->button2->Location = System::Drawing::Point(164, 81);
		this->button2->Name = L"button2";
		this->button2->Size = System::Drawing::Size(75, 23);
		this->button2->TabIndex = 1;
		this->button2->Text = L"Stop";
		this->button2->UseVisualStyleBackColor = true;
		this->button2->Click += gcnew System::EventHandler(this, &MyForm::button2_Click);
		// 
		// progressBar1
		// 
		this->progressBar1->Location = System::Drawing::Point(23, 25);
		this->progressBar1->Name = L"progressBar1";
		this->progressBar1->Size = System::Drawing::Size(231, 23);
		this->progressBar1->TabIndex = 2;
		// 
		// label1
		// 
		this->label1->AutoSize = true;
		this->label1->Location = System::Drawing::Point(30, 59);
		this->label1->Name = L"label1";
		this->label1->Size = System::Drawing::Size(37, 13);
		this->label1->TabIndex = 3;
		this->label1->Text = L"Status";
		// 
		// MyForm
		// 
		this->AutoScaleDimensions = System::Drawing::SizeF(6, 13);
		this->AutoScaleMode = System::Windows::Forms::AutoScaleMode::Font;
		this->ClientSize = System::Drawing::Size(284, 125);
		this->Controls->Add(this->label1);
		this->Controls->Add(this->progressBar1);
		this->Controls->Add(this->button2);
		this->Controls->Add(this->button1);
		this->Name = L"MyForm";
		this->Text = L"MyForm";
		this->ResumeLayout(false);
		this->PerformLayout();

	}

	void MyForm::doSomeWork(Object^ obj) {
		Progress<int>^ progressHandler =gcnew Progress<int>(gcnew Action<int>(this, &MyForm::updateProcess));
		IProgress<int>^ progress = safe_cast<IProgress<int>^>(progressHandler);

		for (size_t i = 0; i <= 100; i++)
		{
			progress->Report(i);
			Thread::Sleep(1000);
		}
	}	

	void MyForm::updateProcess(int i) {
		updateUIdelegate^ UIaction = gcnew updateUIdelegate(this, &MyForm::UpdateUI);
		updateProgresBarDelegate^ ProgressBarAction = gcnew updateProgresBarDelegate(this, &MyForm::updateProgressBar);
		this->BeginInvoke(UIaction, i);
		this->BeginInvoke(ProgressBarAction, i);
	}

	void MyForm::UpdateUI(int i) {
		this->label1->Text = i + "%";
		
	}

	void MyForm::updateProgressBar(int i) {
		this->progressBar1->Value = i;
	}

	void MyForm::button1_Click(System::Object^  sender, System::EventArgs^  e) {		
		if (this->thread->ThreadState == ThreadState::Unstarted) {
			this->thread->Start(this);
		}
		if (this->thread->ThreadState == ThreadState::Suspended){
			this->thread->Resume();
		}

	}

	void MyForm::button2_Click(System::Object^  sender, System::EventArgs^  e) {
		this->thread->Suspend();
	}
}

Oczywiście jest to tylko przykład, teraz trzeba będzie to usprawnić i odpowiednio opakować.

Podobne pytania

0 głosów
1 odpowiedź 118 wizyt
pytanie zadane 27 sierpnia 2023 w C i C++ przez Code_ Użytkownik (520 p.)
0 głosów
3 odpowiedzi 786 wizyt

92,543 zapytań

141,386 odpowiedzi

319,500 komentarzy

61,929 pasjonatów

Motyw:

Akcja Pajacyk

Pajacyk od wielu lat dożywia dzieci. Pomóż klikając w zielony brzuszek na stronie. Dziękujemy! ♡

Oto polecana książka warta uwagi.
Pełną listę książek znajdziesz tutaj.

Akademia Sekuraka

Kolejna edycja największej imprezy hakerskiej w Polsce, czyli Mega Sekurak Hacking Party odbędzie się już 20 maja 2024r. Z tej okazji mamy dla Was kod: pasjamshp - jeżeli wpiszecie go w koszyku, to wówczas otrzymacie 40% zniżki na bilet w wersji standard!

Więcej informacji na temat imprezy znajdziecie tutaj. Dziękujemy ekipie Sekuraka za taką fajną zniżkę dla wszystkich Pasjonatów!

Akademia Sekuraka

Niedawno wystartował dodruk tej świetnej, rozchwytywanej książki (około 940 stron). Mamy dla Was kod: pasja (wpiszcie go w koszyku), dzięki któremu otrzymujemy 10% zniżki - dziękujemy zaprzyjaźnionej ekipie Sekuraka za taki bonus dla Pasjonatów! Książka to pierwszy tom z serii o ITsec, który łagodnie wprowadzi w świat bezpieczeństwa IT każdą osobę - warto, polecamy!

...