c # Método looping e controle
-
06-09-2019 - |
Pergunta
Eu tenho um método que eu gostaria de executar mais e mais again.I gostaria de ser capaz de iniciar e parar este processo.
Eu tenho usado este padrão para algum trabalho de soquete e eu estou querendo saber o que melhorias eu posso fazer?
public delegate void VoidMethod();
public class MethodLooper
{
private VoidMethod methodToLoop;
private volatile bool doMethod;
private readonly object locker = new object();
private readonly Thread loopingThread;
public void Start()
{
if (!doMethod)
{
doMethod = true;
loopingThread.Start();
}
}
public void Stop()
{
if (doMethod)
{
doMethod = false;
loopingThread.Join();
}
}
public void ChangeMethod(VoidMethod voidMethod)
{
if (voidMethod == null)
throw new NullReferenceException("voidMethod can't be a null");
Stop();
lock (locker)
{
methodToLoop = voidMethod;
}
}
public MethodLooper(VoidMethod voidMethod)
{
if (voidMethod == null)
throw new NullReferenceException("voidMethod can't be a null");
methodToLoop = voidMethod;
loopingThread = new Thread(new ThreadStart(_MethodLoop));
}
private void _MethodLoop()
{
VoidMethod methodToLoopCopy;
while (doMethod)
{
lock (methodToLoop)
{
methodToLoopCopy = methodToLoop;
}
methodToLoopCopy();
}
}
}
Solução
Uma versão mais segura seria a de fazê-lo como este:
private readonly object m_locker = new object(); // readonly so it can never be null
private readonly Thread m_workerThread; // readonly so must set in constructor,
// and never can be null afterwards
private Action m_methodToRun;
private volatile bool m_keepGoing = true; // needs to be volatile or else you need to lock around accesses to it.
public Constructor()
{
m_workerThread = new Thread(ThreadWorker);
}
public void SetMethod(Action action)
{
lock(m_locker)
m_methodToRun = action;
}
private void ThreadWorker()
{
while(m_keepGoing)
{
// use a lock to take a local copy in case another thread sets m_methodToRun to null
// while we are processing things
Action methodLocal;
lock(m_locker)
methodLocal = m_methodToRun;
methodLocal(); // call it
// Note: Remember that the underlying method being pointed to must ALSO be
// thread safe. Nothing you do here can make up for that if it is not.
}
}
private void Stop()
{
m_keepGoing = false;
m_workerThread.Join(); // BLOCK and wait for it to finish
}
private void Start()
{
m_keepGoing = true;
m_workerThread.Start();
}
Consulte esta outra questão para os pontos mais delicados sobre volátil vs travamento
Outras dicas
Bem, você deve expressar o doMethodToLoop tão volátil. Como se afirma no MSDN:
"A palavra-chave volátil indica que um campo pode ser modificado no programa por algo como o sistema operacional, o hardware, ou um fio simultaneamente execução."
Eu estou com pressa, mas você deve verificar este tutorial do interruptor no código.