1

コードでMonitor.Pulse(this)を取得してMonitor.Wait(this)をトリガーしようとしています。私のWaitステートメントはすべてPulseなしのある時点で実行されていると思います。5つの異なるオブジェクトによって実行される5つの異なるスレッドがあり、それぞれが異なる優先度のキューを表しています。スレッドの優先度属性(つまり、通常、通常より上など)を使用せずに、各スレッドを特定の優先度で実行しようとしています。とにかく、ポイントは、各スレッドが1回だけ実行され、その後、各キューで実行されるスレッドのMonitor.Wait(this)部分でスタックしているように見えることです。Monitor.Pulse(this)がMonitor.Wait(this)をトリガーせず、サイクルを続行する理由を誰かが知っていますか。各スレッドは、Monitor.Wait(this)とグローバル変数GlobalCountを使用するwhileループによって次々にトリガーされる必要があります。このトリガーが発生する最上位の最初のクラス(Msgクラス)のベータメソッドで問題が発生する必要があると思います。または、私のメインの方法では、その部分に問題があるかどうかはわかりませんが。

何が起こるかというと、数行を実行してから新しい行を開始しますが、それ以外は何も出力しません。コードはまだ実行中です。Monitor.PulseとMonitor.Waitも削除してみましたが、部分的には機能しますが、デルタオブジェクトのベータメソッドがスレッドを実行するたびに、アルファメソッドに置き換えられます。これがなぜであり、PulseとWaitを機能させる方法を誰かが知っていますか?

これが私のコードです(コメントのいくつかを無視してください):

   // StopJoin.cs
using System;
using System.Threading;
using System.Collections;



public class Msg
{
string message;
int priority;

public Msg(string ms, int pr)
{message = ms;
priority = pr;}


// This method that will be called when the thread is started
public void Beta()
{



while(true){

//Console.WriteLine("asdfasdfs");
Console.WriteLine(message+":"+GlobalClass.globalCount);
lock(this)   // Enter synchronization block
{
while((priority - 1) != GlobalClass.globalCount){
//Console.WriteLine(GlobalClass.globalCount);
try
{
// Waits for the Monitor.Pulse in WriteToCell
//Console.WriteLine("beginning");
//Monitor.Wait(this);
//Console.WriteLine("end");
}
catch (SynchronizationLockException e)
{
Console.WriteLine(e);
}
catch (ThreadInterruptedException e)
{
Console.WriteLine(e);
}
if(GlobalClass.globalCount >= 5)
    GlobalClass.globalCount = 0;
}
Console.WriteLine(message+".Beta is running in its own thread.");

for(int i = 0;i<priority;i++)
{
Console.WriteLine("sending message...");

}

if(GlobalClass.globalCount < 5)
    GlobalClass.globalCount = GlobalClass.globalCount + 1;


//Monitor.Pulse(this);   // Pulse tells Cell.WriteToCell that
//Console.WriteLine(GlobalClass.globalCount);
}
}
}
}






public class Alpha
{
Msg the_message = new Msg("Alpha",1);

public void doWork()
{the_message.Beta();}
};




public class Charlie
{
Msg the_message = new Msg("Charlie",2);
public void doWork()
{the_message.Beta();}
};






public class Delta
{
Msg the_message= new Msg("Alpha",3);
public void doWork()
{the_message.Beta();}
};





public class Echo
{
Msg the_message= new Msg("Echo",4);
public void doWork()
{the_message.Beta();}
};







public class Foxtrot
{
Msg the_message= new Msg("Foxtrot",5);
public void doWork()
{the_message.Beta();}
};




static class GlobalClass
{
private static int global_count = 0;

public static int globalCount
{
get{return global_count;}
set{global_count = value;}
}
}






public class Simple
{
public static int Main()
{

GlobalClass.globalCount = 2;

long s = 0;
long number = 100000000000000000;

Console.WriteLine("Thread Start/Stop/Join Sample");

Alpha oAlpha = new Alpha();
Charlie oCh = new Charlie();
Delta oDe = new Delta();
Echo oEc = new Echo();
Foxtrot oFo = new Foxtrot();

// Create the thread object, passing in the Alpha.Beta method
// via a ThreadStart delegate. This does not start the thread.
Thread oThread = new Thread(new ThreadStart(oAlpha.doWork));
Thread aThread = new Thread(new ThreadStart(oCh.doWork));
Thread bThread = new Thread(new ThreadStart(oDe.doWork));
Thread cThread = new Thread(new ThreadStart(oEc.doWork));
Thread dThread = new Thread(new ThreadStart(oFo.doWork));

// Start the thread
oThread.Start();
aThread.Start();
bThread.Start();
cThread.Start();
dThread.Start();

// Spin for a while waiting for the started thread to become
// alive:
while (!oThread.IsAlive);
while (!aThread.IsAlive);
while (!bThread.IsAlive);
while (!cThread.IsAlive);
while (!dThread.IsAlive);

// Put the Main thread to sleep for 1 millisecond to allow oThread
// to do some work:
Thread.Sleep(1);



// Wait until oThread finishes. Join also has overloads
// that take a millisecond interval or a TimeSpan object.
oThread.Join();
aThread.Join();
bThread.Join();
cThread.Join();
dThread.Join();

Console.WriteLine();
Console.WriteLine("Alpha.Beta has finished");

/*
try 
{
Console.WriteLine("Try to restart the Alpha.Beta thread");
oThread.Start();
}
catch (ThreadStateException) 
{
Console.Write("ThreadStateException trying to restart Alpha.Beta. ");
Console.WriteLine("Expected since aborted threads cannot be restarted.");
}
*/


while(s<number)
s++;

// Request that oThread be stopped
oThread.Abort();
aThread.Abort();
bThread.Abort();
cThread.Abort();
dThread.Abort();


return 0;
}
}
4

1 に答える 1

2

あなたのコードには多くの問題が見られますが、あなたに影響を与える主な問題が 2 つあります。Monitorコメントアウトされた呼び出しはコメント化されるべきではないと思いました(コメント化されていない場合、コードは意味がありません)。

Msgまず、各スレッドの下に の新しいインスタンスを作成します。メソッドは(コメント化された 内の)のBeta現在のインスタンスをロックするため、各インスタンスは本質的にそれ自体を待機しています。これは無限の待機になります。MsgMonitor.Wait(this)Monitor.Pulse

一部のMsgインスタンスは のより高い値で作成されるためpriority、ループを完全にスキップしてwhileを呼び出し続ける必要Monitor.Pulseがありますが、そのパルスを待っているものは何もありません。

メソッドの後半でMainは、次のようになります。

    while (!oThread.IsAlive) ;
    while (!aThread.IsAlive) ;
    while (!bThread.IsAlive) ;
    while (!cThread.IsAlive) ;
    while (!dThread.IsAlive) ;

これには欠陥があります。スレッドの実行順序が保証されていないため、上記のコードがデッドロックする可能性は十分にあります。oThreadがすぐに開始されず、スケジュールされて完了まで実行される場合、上記の最終行に到達する前に が完了して「デッド」に dThreadなるケースを簡単に確認できます。dThread

全体として、コードが何を達成しようとしているのかは明確ではありませんが、現状では、毎回デッドロックすると予想されます。

于 2013-02-22T15:59:12.197 に答える