使用多线程遇到的问题

mogu_chulian

        private void ConnectFtp()
        {
            Monitor.Enter(this);
            for (i = 0; i < listView1.Items.Count; i++)
            {
                try
                {
                    FtpWebRequest req;
                    req = (FtpWebRequest)FtpWebRequest.Create(new Uri("ftp://" + listView1.Items[i].SubItems[0].Text));
                    req.Credentials = new NetworkCredential(listView1.Items[i].SubItems[1].Text, listView1.Items[i].SubItems[2].Text);
                    req.KeepAlive = false;
                    req.Method = WebRequestMethods.Ftp.ListDirectory;
                    req.UseBinary = true;
                    WebResponse response = req.GetResponse();
                    response.Close();
                    listView1.Items[i].SubItems[3].Text = "登录成功";
                }
                catch (Exception)
                {
                    listView1.Items[i].SubItems[3].Text = "登录失败";
                }
                Monitor.Exit(this);
            }
        }

在for开始前锁定，防止多线程同时访问一条数据，在for结束前释放掉。
但是会提示     “从不同步的代码块中调用了对象同步方法”。

该怎么改呀？ 坛子的高手忙帮解决一下啊！

站长苏飞

用委托，搜索多线程有例子

mogu_chulian

恩嗯。找到了。不少。我去解决！

mogu_chulian

mogu_chulian 发表于 2014-5-6 03:22
恩嗯。找到了。不少。我去解决！

飞哥，不行啊。怎么能提高处理数据的速度啊。发现多线程根本走不出for。

站长苏飞

也没见你写有多线程啊，

mogu_chulian

额 我用线程池开了三个。但是不知道怎么锁。。功能有for 主要是想让for中的数据读取的快一点。

zeng1988821

使用Lock 将你使用的对象锁定起来

[C#] 纯文本查看 复制代码

private void ConnectFtp()
        {
            Monitor.Enter(this);
            lock (listView1.Items)  //此处为锁定listView1.Items，当次线程在访问时，其他线程处于等待状态，释放以后其他线程自动获得对该对象的访问权限
            {
                for (i = 0; i < listView1.Items.Count; i++)
                {
                    try
                    {
                        FtpWebRequest req;
                        req = (FtpWebRequest)FtpWebRequest.Create(new Uri("ftp://" + listView1.Items[i].SubItems[0].Text));
                        req.Credentials = new NetworkCredential(listView1.Items[i].SubItems[1].Text, listView1.Items[i].SubItems[2].Text);
                        req.KeepAlive = false;
                        req.Method = WebRequestMethods.Ftp.ListDirectory;
                        req.UseBinary = true;
                        WebResponse response = req.GetResponse();
                        response.Close();
                        listView1.Items[i].SubItems[3].Text = "登录成功";
                    }
                    catch (Exception)
                    {
                        listView1.Items[i].SubItems[3].Text = "登录失败";
                    }
                }
            }
            Monitor.Exit(this);
        }