导致SQL查询无法工作的Parallel.ForEach
Parallel.ForEach是一个.NET Framework中的并行循环结构，用于在多个线程上并行执行迭代操作。它可以用于并行处理集合中的元素，提高程序的性能和效率。
然而，当在SQL查询中使用Parallel.ForEach时，可能会导致查询无法正常工作。这是因为SQL查询通常依赖于数据库的事务处理和锁机制来确保数据的一致性和完整性。而使用Parallel.ForEach会导致多个线程同时执行查询，可能会破坏数据库的事务处理机制，导致数据不一致或错误的结果。
为了避免这种情况，应该避免在SQL查询中使用Parallel.ForEach。相反，可以使用其他方法来提高查询的性能，如使用索引、优化查询语句、使用存储过程等。此外，还可以考虑使用数据库的并行处理功能，如并行查询、并行执行计划等。
腾讯云提供了一系列与数据库相关的产品和服务，可以帮助用户提高数据库的性能和可靠性。例如，腾讯云的云数据库SQL Server版（https://cloud.tencent.com/product/cdb_sqlserver）和云数据库MySQL版（https://cloud.tencent.com/product/cdb_mysql）提供了高可用性、自动备份、性能优化等功能，可以满足不同规模和需求的数据库应用场景。
总结：在SQL查询中使用Parallel.ForEach可能会导致查询无法正常工作，因为它破坏了数据库的事务处理机制。为了避免这种情况，应该避免在SQL查询中使用Parallel.ForEach，并考虑使用其他方法来提高查询性能。腾讯云提供了一系列与数据库相关的产品和服务，可以帮助用户提高数据库的性能和可靠性。
相关·内容
您好，我需要向一个域中的每个系统(可能有数千个)发送一个WMI查询，而WMI查询似乎需要很长时间才能返回。因此，我正在审查使用多线程发送多个请求的最佳方法，这样进程就可以在后台运行，并且调用可以重叠。
我喜欢BackgroundWorker提供的功能，我在上读到它在幕后使用ThreadPool。不过，我真的不明白我该如何利用它来达到我的目的。看起来，如果我必须发送1000个查询，我可以做一个循环，在这个循环中，我为每个查询调用一个新的BG worker，而线程池将使用多达25(?)线程，剩余的975个请求将被排队。这是怎么回事吗？
如果这是正确的，我想象将1000个请求排队的过程本身将冻结UI
浏览 4提问于2011-08-03得票数 1
回答已采纳
1回答
从Server并行读取
、、、
我看了几十篇文章，但找不到解决办法。
以下是逻辑：
我有一个Winform (VS2010)应用程序，它需要从Server 2008 R2速成表A读取数据，处理一些计算并存储在不同的表B中。
我想使用并行ForEach来缩短执行时间(否则计算+ SQL进程需要几天……)
我必须从SQL读取，因为数据库有超过500万行，每个read都返回几百行。
名单的定义是：
BindingList<ItemsClass> etqM = new BindingList<ItemsClass>();
BindingList<ItemsClass> etqC = new Bin
浏览 4提问于2012-10-23得票数 2
回答已采纳
当我在Parallel.ForEach中使用VB.net时，我遇到了一个问题，我有一个实体列表，我收到了IEnumerable of objects (myClass)。我想在接收到的对象的每次迭代中获得一些信息，但是当我在parallel.foreach中创建对象时，程序无法工作--这是我的代码：
Friend Sub ChanceSomething(items As IEnumerable(Of Model.myClass))
Dim entity As New Model.myEntity
Dim entities = Me.EntitiesList() &
浏览 0提问于2015-07-13得票数 1
回答已采纳
我正在使用Parallel.ForEach遍历LINQ to SQL映射。一旦处理了一定数量的元素，我就会跳出这个循环。处理过程停止，但是循环挂起了几秒钟，然后我得到了一个错误：
System.Data.SqlClient.SqlErrorCollection: Timeout expired. The timeout period elapsed prior to completion of the operation or the server is not responding.
如何让循环正常退出？通过将ToList()附加到查询来强制本地集合是没有选择的。我还尝试将所有内容包装在u
浏览 1提问于2011-11-29得票数 4
1回答
我正在尝试对链接服务器(链接到Sybase的SQL server 2008 )执行查询，并将其选择到临时表中。通过SQL Management Studio中的查询窗口可以很好地工作，但当我通过代码(C#)执行此操作时，它会失败，并显示错误“无法执行操作，因为链接服务器"MYLINKEDSERVER”的OLE DB提供程序"ASEOLEDB“无法启动分布式事务。我的DbConnection没有在代码中使用事务。”
此查询如下所示：
SELECT *
INTO #temptable
FROM OPENQUERY([MYLINKEDSERVER], 'SELECT * f
浏览 6提问于2010-11-17得票数 1
回答已采纳
我有一个问题，把.AsParallel转换成Parallel.ForEach。我有一个DataGridView，然后用ForEach循环在它的第一列中放置一些值，然后将值发送给方法并得到一个返回值，然后将返回值放到第二列。
一开始，我使用ForEach循环，但这需要太多的时间，然后我决定使用AsParallel，但我认为，在我的情况下，使用Parallel.ForEach可能更好，但我无法使它与datagridviewrow一起工作。
ForEach方法：
foreach (DataGridViewRow dgvRow in dataGrid1.Rows)
{
// SOME C
浏览 3提问于2015-09-30得票数 2
回答已采纳
2回答
我有一个线程，在服务启动时加载数据。我在这个线程中调用一个使用Parallel.Foreach迭代一组数据的方法。但是，我在并行forerach中拥有的linq查询将获得一个未设置为实例错误的objet引用。
*--如果我删除了Parallel.Foreach，或者删除了线程，同样的逻辑也能工作。*甚至锁定列表也没有帮助。*
loadingThread = new Thread(new ThreadStart(PreloadData));
loadingThread.IsBackground = true;
loading
浏览 7提问于2012-04-12得票数 0
回答已采纳
我正在使用Parallel.ForEach在多个线程上工作，为每个迭代使用一个新的EF5 DbContext，所有这些都包装在一个TransactionScope中，如下所示：
using (var transaction = new TransactionScope())
{
int[] supplierIds;
using (var appContext = new AppContext())
{
supplierIds = appContext.Suppliers.Select(s => s.Id).ToArray();
}
浏览 0提问于2013-02-14得票数 9
回答已采纳
1回答
我正在尝试LINQ查询一组文件，在其中我可以找到文件名，其中包含一个特定的字符串。
我用的是：
var docs = directory.enumerateFiles(searchFolder, "* " + strNumber+ "*", SearchOption.AllDirectories);
这是很好的工作，但我的一些文件搜索花费了30+分钟，因为其中一个目录有1+百万个文件。我希望通过PLINQ查询来加快搜索过程。然而，虽然我的语法很好，但我并没有得到预期的结果。看来我的问题可能在Where语句中。任何帮助都会有帮助。
foreach (strNumb
浏览 4提问于2022-03-22得票数 2
回答已采纳
3回答
我有一段代码：
try
{
var files = from folder in paths
from file in Directory.EnumerateFiles(path, pattern, searchOption)
select new Foo() { folder = folder, fileName = file };
Parallel.ForEach(files, new ParallelOptions { MaxDegreeOfParallelism = _maxDegreeOfParalle
浏览 1提问于2014-12-20得票数 5
我的SQL server/DB中有一个表，记录接近100,000条。使用C# -需要通过行循环并进行外部API调用，并将调用结果更新到SQL表中。我是新的多线程概念。我怎样才能做到这一点？
这是我的代码--只是顺序处理。
public void MainProcess()
{
try
{
// Retrieve rows from table
List<rowResult> rowResults = (List<rowResult&g
浏览 4提问于2022-11-10得票数 0
我正在提取SQL文件表中文件的内容。如果我不使用并行，下面的代码可以工作。
当同时(并行)读取文件流时，我将得到以下异常
进程无法访问指定的文件，因为它是在另一个事务中打开的。
TL;DR:
在从FileTable (使用GET_FILESTREAM_TRANSACTION_CONTEXT)读取Parallel.ForEach中的文件时，我会得到上述异常。
示例代码供您试用：
更长版本：
获取附件，并提取内容：
var documents = new List<ExtractedContent>();
using (var ts = new TransactionScop
浏览 0提问于2015-05-11得票数 14
1回答
我有多个阅读器，我想同时运行所有阅读器。我在数据库中使用以下查询从相同的查询中获取读卡器IP和数据： var deviceSetupsInfo = entities.LaneDeviceSetups
.Where(e => e.DeviceTypeId == 1)
.Select(e => new {
e.Ip,
e.LaneId,
e.TableName,
浏览 12提问于2021-02-01得票数 0
1回答
我正在做一个学校项目，需要编写一个查询来过滤数据集到某些变量。我的所有SQL都运行得很好，但我无法让LIKE语句与%-符号一起工作。我相信我的语法错了。有人能告诉我我做错了什么吗。谢谢
守则：
qryMovie.SQL.Clear;
qryMovie.SQL.Add('SELECT * FROM Movies');
qryMovie.SQL.Add('WHERE Genre = ' + QuotedStr(genre));
qryMovie.SQL.Add('AND Price BETWEEN ' + minPrice + ' AND
浏览 2提问于2017-08-07得票数 1
回答已采纳
我有一个要求，那就是我们使用Parallel.ForEach运行一些任务。一次，用户可以决定从提供给Parallel.ForEach的TaskList中取消任何任务或单个任务。我尝试过使用CancellationToken，但它对TaskList中的所有任务都会触发。我也尝试过ParallelLoopState，但即使这样也不能达到我想要的效果。 我使用下面的代码在这个POC上工作，我无法使它工作。 瓶颈在下面的语句中 Parallel.ForEach(nums, new ParallelOptions() { CancellationToken = new CancellationToke
浏览 31提问于2019-12-24得票数 0
1回答
因此，我试图查询一个可以通过HTTP访问的API (没有授权)。为了加快速度，我尝试使用Parallel.ForEach循环，但似乎运行时间越长，出现的错误就越多。
它无法检索越来越多的请求。我知道API提供程序并没有限制我，因为我可以在我的Internet浏览器中请求相同的阻塞URL。而且，每次都有不同的失败URL，因此似乎不存在格式错误的请求。
当我使用单线程的foreach循环时，错误似乎不会发生。
我的故障循环如下：
Parallel.ForEach(this.urlArray, singleUrl => {
this.apiResponseBlob = new System.N
浏览 2提问于2014-12-08得票数 1
回答已采纳
1回答
我正在使用中的SQL来执行针对DB2的查询。问题中的查询工作正常。但是，当我单击“解释”生成访问计划时
“无法生成访问计划图”
诊断文本是
SQL语句失败。说明: SQL语句导致SQLCODE：-204和SQLSTATE: 42704出现错误。用户响应: DB2文档包含有关SQLCODE和如何解决错误的更多信息。"DB2ADMIN.TABLENAME“是一个未定义的名称。SQLCODE=-204，SQLSTATE=42704，DRIVER=3.66.46
这个查询类似于
select col1, col2 from tablename where pred=value
浏览 11提问于2015-09-17得票数 0
回答已采纳
在工作中，我们的一个进程使用SQL数据库表作为队列。我一直在设计一个队列读取器，以检查表中的排队工作，在工作开始时更新行状态，并在工作完成后删除该行。我使用Parallel.Foreach为每个进程提供自己的线程，并将MaxDegreeOfParallelism设置为4。
当队列读取器启动时，它检查是否有未完成的工作，并将工作加载到一个列表中，然后对该列表执行一个Concat，并使用一个方法返回一个在无限循环中运行的IEnumerable，检查要做的新工作。其思想是，未完成的工作应首先处理，然后新的工作可以作为线程可用。然而，我看到的是，FetchQueuedWork将立即将队列表中的数十行更
浏览 4提问于2014-09-23得票数 1
回答已采纳
我尝试了下面的代码，它抛出异常，说明查询需要打开连接，并且当前状态是打开/打开/关闭的。
这是一个创建线程的Parallel.ForEach循环，我希望它们打开到Server数据库的连接，并在其中插入一些内容。在这里，我遵循模式来处理其他问题中的并行性，但它们对我不起作用。
有人能为这件事开点光吗？怎样才能做到这一点？
连接打开错误？
连接闭合误差
private static void CreateResultTable()
{
Parallel.ForEach(_fakeTableFileFull, tableRow =>
浏览 1提问于2017-11-17得票数 2
回答已采纳
我试图在Parallel.Foreach循环中编写单独的集合来分离csv。当我运行这个程序时，我会得到以下错误：
进程无法访问文件'C:\temp\OCRProcess\2011\49\OCRProcess-2011-49.csv‘，因为它正被其他进程使用。
当我查看所有的辅助进程时，它们正在打开不同的文件，它们都没有使用相同的文件位置。据我所知，每个线程(工作进程)并不冲突。
public void GenerateCSVFile(List<CSVFile> csvFiles)
{
Parallel.ForEach(csvFiles, (csvfi
浏览 2提问于2014-01-23得票数 0
回答已采纳
我想并行加载一个任务列表，然后并行执行这些任务。任务以一个方法作为操作，但我需要该方法为每个任务处理不同的对象。但我不能传递参数。
所以我想出一个这样的解决方案：
public static Order order = new Order();
public static Queue<SubOrder> subsQ = order.SubOrders;
public void Work()
{
Task[] taskList = TaskMaker(order.SubOrders.Count);
Task.WaitAll(taskList);
}
public
浏览 9提问于2014-04-10得票数 2
回答已采纳
4回答
我有一个程序可以并行地发送Server实例的多个请求。在我的所有并发请求中，其中一个总是在db.open()上阻塞几秒钟。
void MyMethod()
{
var brands = new List<string>{"Chevy", "Honda", "Ford", "GM"};
var foundCars = new ConcurrentBag<Car>();
Parallel.ForEach(brands, brand =>
{
logg
浏览 4提问于2015-07-20得票数 4
首先，我不是多线程和并行编程方面的专家.
我试图优化遗留应用程序(.Net 4，NHibernate 2.1)的性能。
**到目前为止，升级NHibernate并不是一个优先事项，而是正在酝酿之中。
随着时间的推移，随着数据的增长，性能已经成为一场噩梦。我看到的一个项目是一个Parallel.ForEach语句，它调用一个方法来获取和更新一个复杂的实体(具有多个关系- propeties和集合)。
这段代码具有以下表单(为清晰起见简化)：
void SomeMethod(ICollection<TheClass> itemsToProcess)
{
Parallel.ForE
浏览 4提问于2016-03-01得票数 1
我正在做一个更大的程序，但是它对列表框中的每个值所做的操作需要很长的时间。我想通过对同一个列表视图中的多个值执行相同的处理来加快速度，基本上是尝试添加某种类型的并行操作逻辑来完成工作。
我创建了一个快速程序，它是我正在工作的更大程序的一个非常简单的版本，我希望有人能建设性地为我指明正确的方向。
有没有一种方法可以让我同时从列表的顶部和底部开始，让每个人都按自己的方式工作，直到他们在中间相遇？我没法想别的办法来做这件事。
这里有一个示例‘代码’，说明了我现在使用后台工作人员所做的事情，没有什么特别之处(同样，这是一个模拟程序，因为我正在处理的实际程序的“复杂性”。)
privat
浏览 2提问于2016-11-02得票数 1
回答已采纳
6回答
我使用这个查询将数据提交到数据库中：
$sql = "UPDATE table SET user='$user', name='$name' where id ='$id'";
id将通过url EX localhost/index.php?id=123获得。
$id=$_GET['id']
查询将无法正常工作；数据将不会更新。如果我写道：
$sql = "UPDATE table SET user='$user', name='$name' where id ='1
浏览 0提问于2011-11-29得票数 4
1回答
我有一个应用程序，其中包含一个充满目录路径的列表框。
我正在循环遍历每个目录路径，并提取每个路径上设置的权限。
一开始我把这个当成了一个函数，这样叫.
For Each dirpath In ListBox3.Items
CalculatePermissions(dirpath)
Next
这是可行的，但当然，我的应用程序会挂起，并在很长一段时间内失去响应，而工作正在进行。我递归地查看所有目录和子目录，这样就可以得到很多结果。
我将函数更改为背景工作者并尝试异步调用它，如下所示.
For Each dirpath In ListBox3.Items
bgw_CalcP
浏览 3提问于2017-12-01得票数 1
回答已采纳
我试图使用Parallel.Foreach()并行查询mongo，但没有得到任何结果。但是，当我试图在普通的foreach循环中运行相同的事情时，我能够执行预期的任务。
var exceptions = new ConcurrentQueue<Exception>();
var secondaryObjectsDictionaryCollection = new Dictionary<string, List<JObject>>();
// This works
foreach(var info in infos)
{
try
{
浏览 0提问于2018-11-16得票数 1
回答已采纳
我在尝试将这个SQL查询(在Microsoft 上)执行到一个应用程序时遇到了一些困难。
因此，我有一个执行简单select查询的方法：
public void insertOrUpdate_TIRConsolidatoPolizza(QS_TirPolizza qsTir) throws Exception {
try{
log.debug("PucManager.insertOrUpdate_TIRConsolidatoPolizza");
// Reperisce i parametri della query dal para
浏览 2提问于2016-06-23得票数 1
回答已采纳
工作负载中有一组可以并行运行的项。有时只有1，有时有很多。当我Parallel.ForEach处理一个很大的工作负载时，它明显地更快了。因此，它似乎是Parelle.ForEach的一种合适的使用。
我已经读过，对于1或2的工作负载，最好不要对它们进行Parallel.ForEach。这是否意味着我必须用这种模式包装每个可变工作负载大小的Parallel.ForEach？
if (workItems.Count==1)
{
foreach (MyItem item in workItems)
{
bool failed = WorkItWorkIt(item);
浏览 4提问于2014-04-18得票数 2
回答已采纳
我使用Kepware的客户端与RSLinx OPC Server进行通信。但是，我不能断开RSLinx OPC服务器。当我不使用Parallel.Foreach时，我可以断开服务器连接。但是，当我使用Parallel.Foreach时，我无法断开连接。我没有收到Kepware的客户的回复。如何断开服务器连接？ [code]
DaServerMgt daServerMgt = new DaServerMgt();
...
// Disconnect
daServerMgt.Disconnect(); <--- hanging when I use Parallel.Foreach to
浏览 37提问于2019-08-20得票数 0
1回答
我有一个SQL查询，它适用于我的SQL解决方案。鉴于我目前的位置和软件，我无法使用我的Oracle软件。我目前正在旅行，并试图做一些额外的工作。
我有一个SQL查询：
SELECT tt.supplierId, tt.Price
FROM products tt
INNER JOIN
(SELECT SupplierID, MAX(price) AS [prices]
FROM products
GROUP BY SupplierID ) groupedtt
ON tt.SupplierID = groupedtt.SupplierID
AND tt.price = groupedtt.pr
浏览 2提问于2014-11-04得票数 1
回答已采纳
我正在重写一些代码，以便使用第三方编程语言而不是BackgroundWorkers，并同时实现多线程。我所有的东西都运行得很好(并行运行，取消也可以工作)，但是我不知道如何适当地更新我的进度条。这就是我到目前为止所做的(不打算写完整的任务，因为它很大)：
更新:我已经用我尝试过的一些建议中的更改更新了代码。
var progressHandler = new Progress<int>(value => { pgbOverviewProgressbar.Value = value; });
progress = progressHandler as IProgress<
浏览 1提问于2014-10-29得票数 0
在TSQL中经常使用以下查询：
SELECT COUNT(*), *
FROM CUSTOMER c
WHERE c.Name like 'foo%';
当我试图在Oracle SQL Developer中执行此查询时，它无法工作，并抛出一个错误：
“缺失表达”
好的语法是什么？
提前谢谢。
浏览 4提问于2013-06-19得票数 34
回答已采纳
当我在HQL查询中使用阿拉伯值时，它返回null。 我在MySQL数据源中添加了unicode和UTF。 我获得了从Hibernate查询生成的SQL，并在工作台中运行它，它给出了一个结果： Query q = se.createQuery("from Days where d_name = 'الخميس' " ); 我在工作台上运行生成的SQL查询，它会给出一个结果。我也尝试过用d_id查询，它运行起来没有问题，所以我认为问题出在阿拉伯值上。 我希望返回的结果是一个对象，但它返回的是null！
浏览 21提问于2019-03-24得票数 0
1回答
我收到警告说
进入已处置的关闭
但我看不出在这段代码中是怎么发生的：
private BlockingCollection<PicInfo> listOfPicInfoObjectBC;
private List<PicInfo> CreatePicInfoObjects(List<string> pics)
{
listOfPicInfoObjectBC = new BlockingCollection<PicInfo>();
var cts = new CancellationTokenSource();
t
浏览 0提问于2015-12-12得票数 1
回答已采纳
我很难用并行方式发送电子邮件.以防万一，代码工作得很完美，但是它并不能发送所有的电子邮件。它实际上只发送了一个..。没有错误，并由编译器发送。
MailSender emailHelper = new MailSender(server, serverPort, loginName, password, true);
Parallel.ForEach(File.ReadLines(textBoxListaClientes.Text),
new ParallelOptions { MaxDegreeOfParallelism = 4 },
浏览 2提问于2017-12-19得票数 0
回答已采纳
我使用了很多parallel foreach循环。它们主要用于详细说明数据，并将其添加到列表中。
这是我的方法的一个例子：
System.Threading.Tasks.Parallel.ForEach(magazzini, m =>
{
try
{
warehouse.Add(new WAREHOUSE()
{
ID = m.Id,
NAME = m.new_name,
CODE = m.new_codice,
INTEGRATION_KEY
浏览 2提问于2016-04-01得票数 0
回答已采纳
我想将Parallel.ForEach与List一起使用，但我做不到。
以下是我的当前代码：
class Test1
{
public static List<string> myList = new List<string>();
public object myListToArray()
{
return myList.ToArray();
}
}
class Test2
{
public void Test(){
Task.Factory.StartNew(() => Paralle
浏览 0提问于2017-11-29得票数 2
回答已采纳
3回答
我有一个SQL查询命令。问题是当我键入一个人的全名时，它不会出现。例如，如果我搜索" ermel "，它将显示ermel。但是，当我搜索"ermel lopez“时，它将无法输出查询。以下是我的查询：
$query=mysql_query("select * from persons where firstname like '%$searchtext%' or lastname like '%$searchtext%' order by date desc
LIMIT $start,$per_page
浏览 2提问于2013-08-14得票数 1
回答已采纳
我有以下使用LINQ查询的普通foreach，如何使用转换它
foreach (var i in media.Where(x => x is Video)
{
this.Update(i);
}
我怎么才能像
Parallel.ForEach(media,i =>
{
//LINQ
});
浏览 8提问于2015-01-01得票数 4
回答已采纳
2回答
我在努力学习如何使用第三方物流。我对这一主题做了相当多的阅读，但我不明白为什么下面的代码示例会中断，以及工作后的代码示例为何会中断？
我已经运行了一个单元测试来统计所写的记录，并且读取输出的文件来进行二次检查。
失败：
var tasks = new List<Task>();
Parallel.ForEach(File.ReadLines(featuresLocation), s =>
{
var feature = CreateFeature(s);
if (feature.HasV
浏览 5提问于2013-09-29得票数 4
回答已采纳
在我的本地机器上运行以下代码
Console.WriteLine("Loaded: " + records.Count);
Parallel.ForEach(records, record =>
{
try
{
var client = new HttpClient();
var response = client.SendAsync(new HttpRequestMessage(HttpMethod.Head, Http +
浏览 2提问于2015-09-07得票数 0
2回答
我试图使一个小的应用程序，使用一个列表中的类型列表的多层次，为大约20-30个级别。我尝试过：
System.Collections.ComponentModel.ObservableCollection，但是在运行时，我得到了一个OutOfMemoryException错误。然后，我尝试使用List，这次我没有得到这样的错误。
哪种类型的集合占用的空间最少？或者，什么是实现这种层次结构的好方法？我只需要一个集合；我不需要更改通知等。我使用的是带有VB、Linq和WPF的.NET 4。我使用Parallel.ForEach线程实现了代码循环过程。
编辑:该程序用于将文件系统数据串到Sql CE
浏览 7提问于2012-08-04得票数 0
回答已采纳
我在阅读有关Parallel.ForEach的文章时指出，"Parallel.ForEach与传递异步方法不兼容“。
因此，为了检查一下，我编写了以下代码：
static async Task Main(string[] args)
{
var results = new ConcurrentDictionary<string, int>();
Parallel.ForEach(Enumerable.Range(0, 100), async index =>
{
var res = await DoAsyncJob(index
浏览 0提问于2018-11-27得票数 5
回答已采纳
我需要一个解决方案来插入与sql查询数据库直接类别，但我无法填充路径，级别列值。我可以通过magento ORM填充category表，但有没有任何方法可以通过sql查询将类别直接插入数据库。
提前感谢你们所有人的帮助
浏览 0提问于2015-02-19得票数 0
我正在做一个程序，它详尽地搜索大量排列，并对每个排列运行一个测试，以便根据每一项符合条件的类别积累统计数据。
搜索输入是使用一个返回收益率返回的IEnumerable的方法动态生成的，因此它不是一次累积整个数据集，而是作为它的消耗来生成它。
这对于很小的搜索空间很好，但是当我进入数千亿条记录来检查生成测试用例的过程时，几乎立即耗尽我的机器上的16 my内存，并在任何处理开始之前就开始用页面错误破坏计算机。
似乎正在发生的是，Parallel.ForEach正在贪婪地尝试枚举整个输入集，然后才开始处理任何内容。
因此，我的问题是，如何限制Parallel.ForEach从测试用例生成器请求输入数
浏览 2提问于2014-10-07得票数 1
回答已采纳
我对以下查询语句有一个简单的查询：
<cfquery name="rsProductTypeID" dbtype="query">
SELECT
ProductTypeID
FROM
rsProductTypes
WHERE
ProductType = <cfqueryparam value="Computers" cfsqltype="cf_sql_nvarchar"/>;
</cfquery>
它所做的就是从记录集rsProductType中请求主键值(rsProductType)，这
浏览 5提问于2014-08-15得票数 1
回答已采纳
1回答
我正在尝试使用Parallel.ForEach()构造来进行多线程处理，并且遇到了一些问题。具体来说，需要对一些数据进行不同的评估，这似乎在ForEach()构造中产生了一些问题，其中一些属性是用来自不同线程的值来设置的。我以为我可以简单地用锁包装特定的代码，但问题仍然存在。可以通过检查以下代码来识别问题所在吗？：
以下是内联代码：
using SecurityApi.Core.Models;
using SecurityApi.Core.Repositories;
using System;
using System.Collections.Concurrent;
using System
浏览 0提问于2018-04-16得票数 0
回答已采纳
我的每一行都有一个查询Excel，大约2000个。当我将所有查询复制粘贴到SQL Server中时，大约有100行显示错误。可能甚至不是错误，但查询将粘贴到SQL Server中，并在整个查询前面加上双引号。
我有适当的错误检查，所以它与我的Excel工作表中的数据有关。我的查询粘贴在SQL Server中，例如：
"insert into
我无法粘贴整个查询或任何数据，抱歉。
感谢您关注这篇文章
浏览 0提问于2014-09-30得票数 6
我读过许多其他关于访问修改闭包的问题，所以我理解了基本原理。尽管如此，我还是不知道-- Parallel.ForEach也有同样的问题吗？
以下面的代码片段为例，我重新计算了上周用户的使用状态：
var startTime = DateTime.Now;
var endTime = DateTime.Now.AddHours(6);
for (var i = 0; i < 7; i++)
{
// this next line gives me "Access To Modified Closure"
Parallel.ForEach(allUsers,
浏览 2提问于2014-06-04得票数 4
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
