C# threading

Pozdravljeni,

zanima me mnenje, kako ustvariti program, znotraj katerega bom lahko ustvaril npr. 100 (ali 1000) threadov, počakal, da bodo vsi threadi skreirani in jih pognal hkrati.
Poskusil sem s Thread Pool vendar imam občutek, da se ne izvedejo vsi threadi hkrati, ampak nekateri čakajo na prosto mesto v thread pool za izvajanje.

Aplikacija je za testiranje delovanja podatkovnih baz pri 100 (1000) hkratnih uporabnikih.

Vsaka ideja je dobrodošla :)

Lp,
Uroš

p.s.: moj prvi post, upam da nisem kaj zajebal :)

Niti se tako ali tako izvajajo le navidez sočasno (na enem CPU jedru). Tako da če imaš npr. quad core procesor, se bodo dejansko istočasno lahko izvajale le štiri niti. No, drugače je pri GPU, kjer gre za popolnoma drugo arhitekturo.

@BlueRunner.. se strinjam, da bi bilo za izvedbo testov uporabiti kakšno farmo računalnikov :) Če mi uspe sinhronizirat iz 4ih bo že uspeh. Glede nitenja... ni šlo, ker kot sta z Jean-Paulom že ugotovila, se niti ne izvedejo potem sočasno, ampak čakajo oz. po defaultu se jih 25 začene sočasno, naslednji pa potem čakajo in iščejo 'prosta' mesta, ki se sprostijo, ko se ena nit zaključi. Nitenje sem zaradi tega opustil in skreiral console app, katero kličem iz main app in sicer tako, da pripravim n procesoc te console app, potem pa vse hkrati poženem.

Glede iz trenutnih meritev je omejitev zaenkrat cpu na strežniku (kjer je baza), pri > 50 'klientih' pa pričakujem tudi kako težavo s cpu-jem iz testnih pc-jev. Kot zanimivost, ram ni zaseden skoraj nič.

Ko bom končal, rezultate seveda objavim :)

Vsi predlogi so seveda dobrodošli.

Lp,
Uroš

se niti ne izvedejo potem sočasno, ampak čakajo oz. po defaultu se jih 25 začene sočasno, naslednji pa potem čakajo in iščejo 'prosta' mesta, ki se sprostijo, ko se ena nit zaključi.

To je opis za thread pool. Si prepričan, da si uporabil moj predlog?

BladeRunner, kako se sinhroniziras na event?

using System;
using System.Collections.Generic;
using System.Threading;

namespace ThreadGo
{
	class Program
	{
		private struct ThreadCtx
		{
			public ManualResetEvent SyncEvent;
			public int ThreadId;
		}

		static void Main(string[] args) {
			ManualResetEvent mre;
			List<Thread> threads = new List<Thread>();

			// Create event to start all threads
			mre = new ManualResetEvent(false);

			// Create all threads
			for (int ii = 0; ii < 1000; ii++) {
				threads.Add(new Thread(Fibonacci));
				threads[ii].Start(new ThreadCtx { SyncEvent = mre, ThreadId = ii });
			}

			// Start all threads
			mre.Set();

			// Wait for all threads to finish
			foreach (Thread t in threads) {
				t.Join();
			}
		}

		static void Fibonacci(object state) {
			int a = 0, b = 1, c;
			ThreadCtx tc = (ThreadCtx)state;
			DateTime start, end;


			// Wait for signal to start
			tc.SyncEvent.WaitOne();

			// Calculate fibonacci
			start = DateTime.UtcNow;
			for (int ii = 0; ii < 100; ii++) {
				c = a + b;
				a = b;
				b = c;
				Thread.Yield();
			}
			end = DateTime.UtcNow;

			Console.WriteLine("Thread {0} calculated fibonacci from {1} to {2}", tc.ThreadId, start.ToLocalTime(), end.ToLocalTime());
		}
	}
}

@arjan_t: nisem niti gledal ostalih orodij ker moram narediti svoje meritve in primerjati SqlConnection, ODBC, ... kateri principi povezovanja so hitrejši, na katere baze itd. Poznaš kako orodje, ki bi mi vse to omogočalo?

Lp,
urosm