0

我有线程问题或 BeginInvoke 阻塞了我的数据操作的整个过程,我启动线程或像这样调用

private void StartRetweetMarch(string twStatusId)
{
    foreach (var line in _emailBox.Lines)
    {

        //new Action<object>(Hashtags).BeginInvoke(new Email { twStatus = twStatusId, login = line.Split(':')[0], password = line.Split(':')[1] }, null, null);
        new Thread(new ParameterizedThreadStart(Hashtags)).Start(new Email { twStatus = twStatusId, login = line.Split(':')[0], password = line.Split(':')[1] });
        //_threads.Add(new Action<object>(Hashtags).BeginInvoke(new Email { login = line.Split(':')[0], password = line.Split(':')[1] }, null, null));
        //Thread.Sleep(40000);w
        // new Thread(new ParameterizedThreadStart(Hashtags)).Start(new Email { login = line.Split(':')[0], password = line.Split(':')[1] });
    }
}

但只有这个 foreach 调用的第一个调用,其他的正在等待或类似的东西,我不知道该怎么做。

4

1 回答 1

0

在 Hashtags 方法内部,它看起来不是线程安全的。比如 _proxies 变量,我不确定这个类型,但是如果你只是使用 List<string> 类型,那么你必须使用排他锁来编写。

//Outside of Method...
//Create lock Object
private static object _lock = new Object();

//Inside of Hashtags Method...
//exclusive lock. Inside of code block is thread safe. 
lock (_lock) {
    prox = _proxies[new Random().Next(0, _proxies.Count)];
    _proxies.Remove(prox);
}
于 2013-04-17T04:16:37.313 回答