通过引用传递给线程 C#？

Question

我有一个方法，我打算在它自己的线程上运行，但在设置线程时不知道如何传递引用。

 private void ManageConnections(ref List<string> instanceAddresses) 
        {
            int connected = Instances.Count();

            if(instanceAddresses.Count() > connected)
            {
                int instancesToAdd = instanceAddresses.Count() - connected;

                while(instancesToAdd != 0)
                {
                    Channel channel = new Channel(instanceAddresses[instanceAddresses.Count - instancesToAdd], ChannelCredentials.Insecure);
                    var client = new ConfigurationDirectoryService.ConfigurationDirectoryServiceClient(channel);
                    Instances.Add(client);
                    instancesToAdd--;
                }
            }
        }

期望的行为是，当原始列表（instanceAddresses）更改时，此方法可以开始工作，并且可以设置新客户端并将其添加到另一个列表中。

这是调用线程启动的方法：

 public CDS_Service(ref List<string> instanceAddresses)
        {
            Thread manageAvaliable = new Thread(CheckAvaliability);
            manageAvaliable.Start();

            if(instanceAddresses.Count() > 0)
            {
                foreach(string instanceAddr in instanceAddresses)
                {
                    Channel channel = new Channel(instanceAddr, ChannelCredentials.Insecure);
                    var client = new ConfigurationDirectoryService.ConfigurationDirectoryServiceClient(channel);
                    Instances.Add(client);
                }

                foreach(CM commandManager in Instances[0].SyncDirectory(new Empty { }).CommandManagers)
                {
                    List<string> commands = new List<string>();

                    foreach(string command in commandManager.Commands)
                    {
                        commands.Add(command);
                    }

                    Directory.Add(new CommandManager(commandManager.Address, commands, commandManager.IsActive));
                }
            }

//Thread would be setup here
        }

这是在哪里构造的：

Server server = new Server
            {
                Services = { ConfigurationDirectoryService.BindService(new CDS_Service(ref clientDiscovery.OtherInstances)) },
                Ports = { new ServerPort(addr, PORT, ServerCredentials.Insecure) }
            };

我也不确定这是否也是通过不同类传递 ref 的不好做法。

这可能/安全吗？

Answer 1

此处不应使用ref，而应使用可观察的集合，例如ObservableCollection<T>。 List<string> 已经是传递引用:)

首先将clientDiscovery.OtherInstances的类型改为ObservableCollection<string>，然后将构造函数的参数类型也改为ObservableCollection<string>。删除所有refs，你不需要那些。

现在，将ManageConnections 重写为这个签名（你需要using System.Collections.Specialized）：

private void ManageConnections(object sender, NotifyCollectionChangedEventArgs e) {

}

在这里，您将检查 e.NewItems 以查看哪些项目已添加到 instanceAddresses 列表中，并将它们中的每一个添加到另一个列表中：

foreach (var item in e.NewItems) {
    Channel channel = new Channel(item, ChannelCredentials.Insecure);
    var client = new ConfigurationDirectoryService.ConfigurationDirectoryServiceClient(channel);
    Instances.Add(client);
}

如果还有已删除的项目，您可能想要做一些事情。如果你想处理这个问题，请使用e.OldItems。这些是删除的项目。

现在，您无需调用ManageConnections，而是：

instancesToAdd.CollectionChanged += ManageConnections;

请注意，这不会处理列表中的初始项（只会添加后续更改），因此您可能希望直接在上述行之后处理初始项。

Answer 2

您不需要ref 关键字。 List<T> 是一个引用类型的类，所以它已经通过引用传递了。

嗯，准确地说，您是在传递引用，而那是按值传递的。如果您将引用分配给新的/不同的列表并希望将其传递回调用者，则只需要 ref 关键字。

如果您不打算更改列表，那么您最好传递IEnumerable<T>，因为它是只读的。List<T> 已经实现了IEnumerable<T>，因此您甚至不需要强制转换。

如果您从不同的线程访问列表，请注意它可能随时更改（例如在迭代过程中途）。在这种情况下，您可能需要一个ConcurrentList<T>，它至少对于添加/删除是线程安全的。或者，如果您只是在阅读，您最好在某个时间点创建列表的只读“快照”，方法是在其上调用 ToArray() 或其他东西并传递它。