|
I am trying to track down a problem with communications and began using Mutex to combate the problem. I have various functions that each call the same Mutex:
public bool function1()<br />
{<br />
Mutex mutex = new Mutex(false, "MyMutex");<br />
mutex.WaitOne();<br />
Console.WriteLine("mutex entered");<br />
Console.WriteLine("mutex exiteded");<br />
mutex.ReleaseMutex();<br />
<br />
return Give_Status;<br />
}<br />
public bool function2()<br />
{<br />
Mutex mutex = new Mutex(false, "MyMutex");<br />
mutex.WaitOne();<br />
Console.WriteLine("mutex entered");<br />
Console.WriteLine("mutex exiteded");<br />
mutex.ReleaseMutex();<br />
<br />
return Give_Status;<br />
}<br />
According to c#Help you can call it this way and as long as it has the same name, it will work.
It is not working however. Here is a sample of the output.
mutex exited
8/8/2005 12:47:08 PM Enter WriteStream byte[]:System.Byte[],False
8/8/2005 12:47:08 PM Enter WriteBuffer
mutex entered
DummyValue
8/8/2005 12:47:08 PM Leaving WriteStream byte[]:True
8/8/2005 12:47:08 PM Enter ReadStream byte[]:5
8/8/2005 12:47:08 PM Enter readBuffer
8/8/2005 12:47:08 PM Leaving ReadStream:System.Byte[]
8/8/2005 12:47:08 PM Enter Flush()
8/8/2005 12:47:08 PM Clear Write Req. Queue = 0
8/8/2005 12:47:08 PM Clear Read Req. Queue = 0
8/8/2005 12:47:08 PM Leaving Flush()
8/8/2005 12:47:08 PM Enter WriteStream byte[]:System.Byte[],False
8/8/2005 12:47:08 PM Enter WriteBuffer
mutex exited
mutex entered
DummyValue
8/8/2005 12:47:08 PM Leaving WriteStream byte[]:True
8/8/2005 12:47:08 PM Enter ReadStream byte[]:5
8/8/2005 12:47:08 PM Enter readBuffer
8/8/2005 12:47:08 PM Leaving ReadStream:System.Byte[]
8/8/2005 12:47:08 PM Enter Flush()
8/8/2005 12:47:08 PM Clear Write Req. Queue = 0
8/8/2005 12:47:08 PM Clear Read Req. Queue = 0
8/8/2005 12:47:08 PM Leaving Flush()
8/8/2005 12:47:08 PM Enter WriteStream byte[]:System.Byte[],False
8/8/2005 12:47:08 PM Enter WriteBuffer
8/8/2005 12:47:08 PM Leaving WriteStream byte[]:True
mutex exited
mutex entered
DummyValue
mutex entered
Notice on the end here, I entered mutex without exiting!!!!
Any idea what would be causing this.
*****************
"We need to apply 21st-century information technology to the health care field. We need to have our medical records put on the I.T." —GW
|
|
|
|
|
The code and the result does not match. In the code you use the typo "exiteded", but that is not present in the output. How much more have you changed in the code before you ran it to create the output?
You might think that I am picky, but I have several times spent time to find peoples errors where there were none, in code that was not even used...
---
b { font-weight: normal; }
|
|
|
|
|
The output is a copy paste... the code I tried to simplify.
Here is a copy paste from one of the functions (no changes)
<br />
public bool commandExitServiceMode()<br />
{<br />
Mutex mutex = new Mutex(false, "MyMutex");<br />
mutex.WaitOne();<br />
Console.WriteLine("mutex entered");<br />
<br />
if ( OpenPort() == false )<br />
Give_Status = false;<br />
else<br />
{<br />
Give_Status = false;<br />
byteToSend = new byte[3];<br />
byteToSend[0] = CMDEXITSERVICEMODE;<br />
sum_xmit_bfr(0);<br />
if(sendAndGetData(3,5))<br />
Give_Status = true;<br />
else<br />
{<br />
MessageBox.Show("Command Fail received from PCC-III to ExitServiceMode");<br />
Give_Status = false;<br />
}<br />
}<br />
Console.WriteLine("mutex exited");<br />
mutex.ReleaseMutex();<br />
<br />
return Give_Status;<br />
}<br />
There are about 10 of these different ones, all have the opening and closing mutex related lines.
*****************
"We need to apply 21st-century information technology to the health care field. We need to have our medical records put on the I.T." —GW
|
|
|
|
|
Maybe one of your Mutex protected functions called another Mutex protected one? Because they are on the same thread, the mutex won't block and you'll enter the mutex immediately. Or maybe there is a typo in one of your Mutex constructors that causes a new Mutex to be created?
That aside, are these functions spread across processes? Mutexes are heavyweight, so I'd prefer Monitor.Enter and Exit, unless of course synchronization needs to be cross process.
Regards
Senthil
_____________________________
My Blog | My Articles | WinMacro
|
|
|
|
|
I have verified that no errors in typing the construct of the Mutex. I also verified that no function calls another mutex controlled function. However, you may be on to something. In the last go around with this, I am calling the same function 4-5 times. The idea is something like:
<br />
<br />
for(int i=1; i<5; i++)<br />
{<br />
public bool mutexControlledFunction();<br />
}<br />
<br />
mutexControlledFunction()<br />
{<br />
Mutex mutex = new Mutex(false, "MyMutex");<br />
mutex.WaitOne();<br />
Console.WriteLine("mutex entered");<br />
<br />
<br />
Console.WriteLine("mutex exited");<br />
mutex.ReleaseMutex();<br />
return Give_Status;<br />
}<br />
There was one early return that I put a breakpoint on to verify that is never ran (it did not) so I know all of the mutex.ReleaseMutex() were run. My understanding is this is the way Mutex is supposed to work. I know that there can not be a typo, because it is calling the same function.
Also, I went with Mutex because it can be declared in multiple places and work together. I am not sure if Monitor has the same functionality. I have about ten functions that all need to be able to wait for the right to process. Only one of these ten can be running at the same time.
If there is a better way to do this, I am open to suggestions.
Thanks so much,
Dwayne
*****************
"We need to apply 21st-century information technology to the health care field. We need to have our medical records put on the I.T." —GW
|
|
|
|
|
As S. Senthil Kumar says, there could be a typo somewhere in a mutex construction. This is one of the places where the use of a constant would be a Good Thing.
Another thing: I don't know if you've taken care of errors in your methods, but I definately would use a construct like this:
public sealed class MyClass
{
public static readonly string MUTEX_ID = "MyMutex";
private readonly Mutex myMutex;
public MyClass()
{
myMutex = new Mutex(false, MUTEX_ID);
}
internal void Foo()
{
myMutex.WaitOne();
try
{
}
finally
{
myMutex.ReleaseMutex();
}
}
}
"God doesn't play dice" - Albert Einstein
"God not only plays dice, He sometimes throws the dices where they cannot be seen" - Niels Bohr
|
|
|
|
|
Thanks for the reply.
Please see my post above as there are some more questions.
Again, thanks for the help.
*****************
"We need to apply 21st-century information technology to the health care field. We need to have our medical records put on the I.T." —GW
|
|
|
|
|
If there isn't a typo, then I don't see where the bug is.
But, if you're not concerned about process synchronization and you need mutual exclusion, then you can use the lock keyword:
public class SomeClass
{
public static readonly object LOCK_OBJECT = new object();
}
public class MyFirstClass
{
public void Foo()
{
lock(SomeClass.LOCK_OBJECT)
{
}
}
}
public class MySecondClass
{
public void Bar()
{
lock(SomeClass.LOCK_OBJECT)
{
}
}
}
This approach is much faster and cleaner.
"God doesn't play dice" - Albert Einstein
"God not only plays dice, He sometimes throws the dices where they cannot be seen" - Niels Bohr
|
|
|
|
|
These functions are return type bool. If I return from inside the lock will it unlock? thanks again.:
<br />
public class MyFirstClass<br />
{<br />
public bool Foo()<br />
{<br />
lock(SomeClass.LOCK_OBJECT)<br />
{<br />
return some_bool;
}<br />
return some_bool;
}<br />
}<br />
*****************
"We need to apply 21st-century information technology to the health care field. We need to have our medical records put on the I.T." —GW
|
|
|
|
|
Dwayner79 wrote:
If I return from inside the lock will it unlock?
Yes.
"God doesn't play dice" - Albert Einstein
"God not only plays dice, He sometimes throws the dices where they cannot be seen" - Niels Bohr
|
|
|
|
|
<br />
public class LockClass<br />
{<br />
public static readonly object LOCK_OBJECT = new object();<br />
}<br />
<\code><br />
In another class in the same namespace:<br />
<code><br />
public bool commandUnForceAll()<br />
{<br />
lock(LockClass.LOCK_OBJECT)<br />
{<br />
<br />
if ( OpenPort() == false )<br />
Give_Status = false;<br />
else<br />
{<br />
Give_Status = false;<br />
byteToSend = new byte[3];<br />
byteToSend[0] = CMDUNFORCEALL;<br />
sum_xmit_bfr (0);<br />
if (sendAndGetData(3, 5))<br />
Give_Status = true;<br />
else<br />
{<br />
MessageBox.Show("Command Fail received from PCC-III to CommandUnForceAll()");<br />
Give_Status = false;<br />
}<br />
<br />
}<br />
}<br />
return Give_Status;<br />
}<br />
<br />
<br />
public bool commandForceBlockOutput(int block, int blockOutput)<br />
{<br />
lock(LockClass.LOCK_OBJECT)<br />
{<br />
<br />
if ( block < 3)<br />
{<br />
MessageBox.Show(this, "Cannot Force blocks 0-3");<br />
return false;<br />
}<br />
if ( OpenPort() == false )<br />
Give_Status = false;<br />
else<br />
{<br />
Give_Status = false;<br />
byteToSend = new byte[6];<br />
byteToSend[0] = CMDFORCEBLOCKOUTPUT;<br />
byteToSend[1] = Convert.ToByte(block);<br />
byteToSend[2] = Convert.ToByte(((blockOutput & -256) / 256) & 255);<br />
byteToSend[3] = Convert.ToByte(blockOutput & 255);<br />
sum_xmit_bfr(3);<br />
if (sendAndGetData(6,5))<br />
Give_Status = true;<br />
else<br />
{<br />
MessageBox.Show("Command Fail received from PCC-III to CommandForceBlockOutput(" + block + ")");<br />
Give_Status = false;<br />
}<br />
}<br />
}<br />
return Give_Status;<br />
}<br />
I am at a lost as to why this will not work. I am so very greatful for all your help.
*****************
"We need to apply 21st-century information technology to the health care field. We need to have our medical records put on the I.T." —GW
|
|
|
|
|
There is one thing that annoys me  , and that is your use of a member variable as a return value. When doing that, you take on the burden to be sure that access to that variable is synchronized too.
It's just a little thing, but add more of that, and you'll soon end up in a situation where you can't figure out why variable x suddenly changes its value.
If you have to use a member variable, be sure to declare it volatile. This ensures that the system doesn't use a cached value for performance reasons, but actually reads the value from the object heap.
"God doesn't play dice" - Albert Einstein
"God not only plays dice, He sometimes throws the dices where they cannot be seen" - Niels Bohr
|
|
|
|
|
You are right. I will change that to a local variable. The other thing that bothers me about the code (this is not my code... I just get to troubleshoot/fix it) is this use of byteToSend as a member array. The 10 different functions reinitialize the array to the size needed then call sendAndGetData() which actually writes to a controller via the serial port. Instead of passing these values to sendAndGetData, it is a member variable. I have not figured out the best way around this.
But that is another story.
*****************
"We need to apply 21st-century information technology to the health care field. We need to have our medical records put on the I.T." —GW
|
|
|
|
|
I didn't see it before, but there is only on condition I can think of that would give this output (considered that there really isn't a typo).
public bool function1()
{
Mutex mutex = new Mutex(false, "MyMutex");
mutex.WaitOne();
Console.WriteLine("mutex entered");
<span style='color: red; font-weight: bolder;'>
</span>
Console.WriteLine("mutex exiteded");
mutex.ReleaseMutex();
return Give_Status;
}
"God doesn't play dice" - Albert Einstein
"God not only plays dice, He sometimes throws the dices where they cannot be seen" - Niels Bohr
|
|
|
|
|
To combat this, I wrapped everything into a try catch block. No exceptions thrown. I have changed everything over to the Lock method you suggested. I copied and pasted into the functions and verified no typos.
I am at a loss. Thanks for your help. I could post more code if you think it would help.
*****************
"We need to apply 21st-century information technology to the health care field. We need to have our medical records put on the I.T." —GW
|
|
|
|
|
There are some things that you can rely on:
1. Only one thread will have access to code inside the lock block.
2. If you still get output like this:
entered lock block
exiting lock block
entered lock block
entered lock block
from code like this:
public void Foo()
{
lock(lockObject)
{
Console.WriteLine("entered lock block");
Console.WriteLine("exiting lock block");
}
}
Then // Some code must have thrown an exception which was caught and ignored, or logged somewhere else than std output, in the method that invoked Foo(). The only alternative, is that the first WriteLine invocation is placed outside the lock statement.
"God doesn't play dice" - Albert Einstein
"God not only plays dice, He sometimes throws the dices where they cannot be seen" - Niels Bohr
|
|
|
|
|
From MSDN:
"While a mutual-exclusion lock is held, code executing in the same execution thread can also obtain and release the lock. However, code executing in other threads is blocked from obtaining the lock until the lock is released."
This makes it sound like this will only work in multiple threads. A for loop is one thread... is it not.
Also,
There are two functions being called. Both have to work off the same lock. I tried it with one and it works. I apologize for the confussion. Fromt he original post, I need both functions to work off the same lock. This is what is not working. I can poll the one function (just did 100 times in a row) and it worked fine. when I poll two functions it fails.:
for(int i =1; i < 5; i++)
{
lockedFunction1()
lockedFunction2()
}
What is happening then is this output:
Function1 entered
Function1 exited
Function2 entered
Function1 entered
Function1 exited
Function2 exited (but with an error because value are not right because of mixup.
*****************
"We need to apply 21st-century information technology to the health care field. We need to have our medical records put on the I.T." —GW
|
|
|
|
|
My point is if there were an exception, we would never see the second function eventually exit.
Sorry that was not very clear.
*****************
"We need to apply 21st-century information technology to the health care field. We need to have our medical records put on the I.T." —GW
|
|
|
|
|
It's the second method call that's the problem. No mutex, monitor or lock statement can help you here as they are all concerned about threading.
But the output clearly says that you're running multithreaded. The lockedFunction2() invocation will not execute before lockedFunction1() is finished. To get the output you display, lockedFunction1(), lockedFunction2() or both must start another thread that outputs the text.
To test for this you could make this change to the output routine:
Console.WriteLine("function 1 entered in thread: " + System.Threading.Thread.CurrentThread.GetHashCode() );
if the hashcode differs in the output, then it's another thread. If it doesn't, then call an Exorcist 
"God doesn't play dice" - Albert Einstein
"God not only plays dice, He sometimes throws the dices where they cannot be seen" - Niels Bohr
|
|
|
|
|
Know any good ones 
entered commandSetBlockParameter in thread: 20
Exited commandSetBlockParameter in thread: 20
entered queryBlockParameter in thread: 20
entered commandSetBlockParameter in thread: 20
Exited commandSetBlockParameter in thread: 20
entered queryBlockParameter in thread: 20
entered commandSetBlockParameter in thread: 20
Exited commandSetBlockParameter in thread: 20
entered queryBlockParameter in thread: 20
Exited queryBlockParameter in thread: 20
Exited queryBlockParameter in thread: 20
That said, Let me add another issue. This is in a timer loop. The timer was ticking before the last passthrough finished. I can disable the timer until the loop completes than reenable it. This may be the only way to fix this.
However, The same problem happens elsewhere when I subscribe to an event and I end up writing two values. I will have to fix this and do more testing. Please do not give up on me. You have been a HUGE help. If I respond in a day, will you be here, or should I start a new thread?
Thanks so much...
Dwayne
*****************
"We need to apply 21st-century information technology to the health care field. We need to have our medical records put on the I.T." —GW
|
|
|
|
|
ok. I have updated the rest of the code and am able to stop it from happening in the timer by disabling it and reenabling it after the loop completes. The same problem still applies to when I subscribe to an event, this launches a new set of code (still in the same thread according to the output) that runs and overlaps.
For instance... the original description of two userControls each calling the same communications function. When the user selects the second control it send a stop message to the first control, but that does not stop the form from continuing through it's timer poll. It is in these transitions that the problem still happens.
-Dwayne
*****************
"We need to apply 21st-century information technology to the health care field. We need to have our medical records put on the I.T." —GW
|
|
|
|
|
I'm baffled. I can't imagine how you can possibly get such a result. Look at this, ugly, code:
using System;
using System.Threading;
using System.IO;
namespace ConsoleTestApp
{
public class MyClass
{
private Timer timer;
public static void Main(string[] args)
{
MyClass myClass = new MyClass();
using (FileStream fileStream = File.OpenWrite(@"C:\test.txt"))
{
using (StreamWriter sw = new StreamWriter(fileStream))
{
Console.SetOut(sw);
myClass.Start();
Thread.Sleep(10000);
myClass.Stop();
Thread.Sleep(1000);
}
}
}
public void Start()
{
timer = new Timer( new TimerCallback(MyTimerCallback), null, 0, 500 );
}
public void Stop()
{
timer.Dispose();
}
private void MyTimerCallback(object state)
{
for (int i = 0; i < 5; i++)
{
Foo();
}
}
private void Foo()
{
lock (this)
{
Console.WriteLine("Entered lock block in thread " + Thread.CurrentThread.GetHashCode());
Thread.Sleep(100);
Console.WriteLine("Leaving lock block in thread " + Thread.CurrentThread.GetHashCode());
}
}
}
}
It doesn't produce the outcome you get. Does your code look something like this?
"God doesn't play dice" - Albert Einstein
"God not only plays dice, He sometimes throws the dices where they cannot be seen" - Niels Bohr
|
|
|
|
|
Not really.
It would be more like:
using System;
using System.Threading;
using System.IO;
namespace ConsoleTestApp
{
public class MyClass
{
private Timer timer;
public static void Main(string[] args)
{
MyClass myClass = new MyClass();
timer.Interval=100;
timer.Enabled=true;
timer.Tick += new System.EventHandler(this.timer_Tick);
}
public void timer_Tick()
{
Foo1();
Foo2();
}
private void Foo1()
{
lock(LockClass.LOCK_OBJECT)
{
Console.WriteLine("Entered lock block in thread " + Thread.CurrentThread.GetHashCode());
Thread.Sleep(100);
Console.WriteLine("Leaving lock block in thread " + Thread.CurrentThread.GetHashCode());
}
}
private void Foo2()
{
lock(LockClass.LOCK_OBJECT)
{
Console.WriteLine("Entered lock block in thread " + Thread.CurrentThread.GetHashCode());
Thread.Sleep(200);
Console.WriteLine("Leaving lock block in thread " + Thread.CurrentThread.GetHashCode());
}
}
}
public class LockClass
{
public static readonly object LOCK_OBJECT = new object();
}
}
This was typed so my syntax may not be exact. There is also no start and stop events. this is mainly to let you get the idea.
As you can see it takes more time for the Foos to run that it takes for the timer to start the next tick. so the timer ticks and foo1 is started again while foo2 is still running.
So instead of this... I am putting the following in the Timer code:
public void timer_Tick()
{
try
{
timer.enabled = false;
Foo1();
Foo2();
}
finally
{
timer.enabled = true;
}
}
It is a patch, but it works. I am uncertain of the TimerCallBack. I will spend tonight figuring out that. Perhaps I am not using the Timer properly.
I must admit, I had/have little experience with the timers.
The other problem is when I subscribe to an event:
using System;
using System.Threading;
using System.IO;
namespace ConsoleTestApp
{
public class MyClass
{
private Timer timer;
private bool doStop1;
private bool doStop2;
private Button RunFoo2;
public static void Main(string[] args)
{
MyClass myClass = new MyClass();
timer1.Interval=100;
timer1.Enabled=true;
timer1.Tick += new System.EventHandler(this.timer_Tick);
timer2.Interval=100;
timer2.Enabled=false;
timer2.Tick += new System.EventHandler(this.timer_Tick);
RunFoo2.Click += new System.EventHandler(this.RunFoo2_Click);
}
public void RunFoo2_Click()
{
doStop1 = true;
timer2.enabled = true;
}
public void timer1_Tick()
{
try
{
timer1.enabled = false;
Foo1();
Foo2();
}
finally
{
if(!doStop1)
{
timer1.enabled = true;
}
}
}
public void timer2_Tick()
{
try
{
timer2.enabled = false;
Foo1();
Foo2();
}
finally
{
if(!doStop2)
{
timer2.enabled = true;
}
}
}
private void Foo1()
{
lock(LockClass.LOCK_OBJECT)
{
Console.WriteLine("Entered lock block in thread " + Thread.CurrentThread.GetHashCode());
Thread.Sleep(100);
Console.WriteLine("Leaving lock block in thread " + Thread.CurrentThread.GetHashCode());
}
}
private void Foo2()
{
lock(LockClass.LOCK_OBJECT)
{
Console.WriteLine("Entered lock block in thread " + Thread.CurrentThread.GetHashCode());
Thread.Sleep(200);
Console.WriteLine("Leaving lock block in thread " + Thread.CurrentThread.GetHashCode());
}
}
}
public class LockClass
{
public static readonly object LOCK_OBJECT = new object();
}
}
Thanks again.
-Dwayne
*****************
"We need to apply 21st-century information technology to the health care field. We need to have our medical records put on the I.T." —GW
|
|
|
|
|
hello friends
Reading c# books take a lot of my time
please can somebody give me a site where i can download
free C# videos
|
|
|
|
|
General 
News 
Suggestion 
Question 
Bug 
Answer 
Joke 
Praise 
Rant 
Admin 
Submit an article or tip
