为什么在SemaphoreSlim发布之前，我的另一个线程仍然可以访问？
在SemaphoreSlim发布之前，另一个线程仍然可以访问的原因是SemaphoreSlim是一个信号量机制，用于控制并发访问资源的数量。它可以限制同时访问某个资源的线程数量，通过调用Wait方法来申请访问资源，如果当前已经达到了最大并发数，则线程会被阻塞，直到有其他线程释放资源。
在SemaphoreSlim发布之前，如果没有使用信号量机制，那么多个线程可以同时访问同一个资源，可能会导致数据竞争和不一致的结果。而SemaphoreSlim的引入可以有效地解决这个问题，通过限制并发访问的线程数量，确保资源的安全访问。
SemaphoreSlim的优势在于它是一个轻量级的同步机制，相比于传统的锁机制，它的开销更小，性能更高。它可以灵活地控制并发访问的线程数量，可以根据实际需求进行调整。
SemaphoreSlim的应用场景包括但不限于：
- 控制数据库连接池的并发访问数量，避免连接过多导致性能下降。
- 控制文件读写的并发访问数量，避免多个线程同时写入导致数据损坏。
- 控制网络请求的并发访问数量，避免同时发送大量请求导致服务器负载过高。
- 控制线程池中任务的并发执行数量，避免线程过多导致系统资源耗尽。
腾讯云提供了一系列与云计算相关的产品，其中包括云服务器、云数据库、云存储等。具体推荐的产品取决于具体的应用场景和需求。您可以访问腾讯云官网（https://cloud.tencent.com/）了解更多关于腾讯云的产品和服务。
相关·内容
2回答
C#中的节流线程
、、、
我遇到了一种情况，在这种情况下，我正在对服务执行WebAPI调用，有时无法跟上负载。我正在跟踪WebAPI响应所需的时间，以及我有多少活动线程，以及当WebAPI需要很长时间来响应时，我希望将并发调用的数量限制在一个特定的数目(我会将其保存在一个配置中)。
我当时想的是使用SemaphoreSlim，但问题是，当时并发线程的数量很可能比我限制的数量还要多。是否有一种解决这个问题的巧妙方法，而不需要重新发明车轮？
浏览 10提问于2022-12-04得票数 1
回答已采纳
1回答
我有以下代码：
private static async Task SaveAsync()
{
if (Monitor.TryEnter(_SaveLock, 1000))
{
try
{
Logging.Info(" writing bitmex data to database");
await SomelenghthyDbUpdate1.ConfigureAwait(false);
浏览 0提问于2019-09-11得票数 1
回答已采纳
我们正在使用Xamarin为安卓和ios编写C#代码和SQLite。然而，关于如何使用sqlite，我似乎有一个概念上的误解：
根据stackoverflow的答案，它说-一个助手和一个数据库连接。在它周围使用lock，以确保任何时候只有一个线程访问sqlite db。
我的问题是-如果是这样的话-异步有什么用？
我尝试将异步与同步代码一起使用--代码正确地给了我编译错误以避免死锁。
public async Task InsertAsync<T> (T item){
lock (mutex) {
await asyncConne
浏览 2提问于2014-06-12得票数 5
回答已采纳
3回答
这是我的代码，但我不明白SemaphoreSlim在做什么。
async Task WorkerMainAsync()
{
SemaphoreSlim ss = new SemaphoreSlim(10);
List<Task> trackedTasks = new List<Task>();
while (DoMore())
{
await ss.WaitAsync();
trackedTasks.Add(Task.Run(() =>
{
DoPollingT
浏览 2提问于2013-11-19得票数 113
回答已采纳
SemaphoreSlim有一个接受CancellationToken的WaitAsync()方法。当这个令牌被取消时，我希望信号量会被释放，但情况似乎并非如此。考虑下面的守则：
var tokenSource = new CancellationTokenSource();
var semaphore = new SemaphoreSlim(1, 1);
// CurrentCount is 1
await semaphore.WaitAsync(tokenSource.Token);
// CurrentCount is 0 as we'd expect
tokenSource.
浏览 0提问于2021-11-17得票数 0
回答已采纳
2回答
我正在讨论下面的问题，无法解决。
我无法解决这个问题，因为“等待”不能包含在锁中，并且不希望使用异步锁实现，因此寻找您的想法可以帮助我用一个简单的解决方案解决这个问题。
浏览 7提问于2022-04-02得票数 0
回答已采纳
6回答
我代码的一部分-隐藏：
object _sync = new object();
private async void OnKeyDown(object sender, KeyEventArgs e) {
if (!Monitor.TryEnter(_sync)) return;
Trace.Write("taken...");
await Task.Delay(TimeSpan.FromSeconds(5));
Trace.WriteLine(" done");
Monitor.Exit(_sync);
}
输出(
浏览 6提问于2014-01-28得票数 19
回答已采纳
2回答
为什么BCL中没有AutoResetEventSlim类？
是否可以使用ManualResetEventSlim进行模拟
浏览 1提问于2011-11-22得票数 38
回答已采纳
我试图同步前台和BackgroundAgent之间对BackgroundAgent的访问。问题是，当我进入锁时，我有一个线程，但是在等待存储访问之后，线程是另一个线程，我得到了SynchronizationLockException。有没有人知道解决这个问题的方法。为什么线程在一开始是不同的？谢谢
浏览 5提问于2014-08-16得票数 0
回答已采纳
2回答
我正在开发一个web应用程序，其中多个用户可以更新相同的记录。因此，为了避免用户同时更新相同的记录时出现问题，我将他们的更改保存在一个队列中。每次保存时，我希望调用一个在另一个线程上处理队列的方法，但我需要确保该方法在再次被调用时不能在另一个线程中运行。我已经读了几篇关于这个主题的文章，但不确定哪篇文章最适合我的情况。下面是我现在拥有的代码。这是正确的处理方法吗？
public static class Queue {
static volatile bool isProcessing;
static volatile object locker = new Object();
浏览 2提问于2013-12-28得票数 6
回答已采纳
以前，我使用sqlite库来执行我的所有sqlite数据库任务，它运行得很好。但是我的应用程序有大量的数据要插入，而且花费了很多时间。因此，我决定只在需要批量插入的地方使用SQLITE包装器，因为SQLITE包装器似乎提供了一些特性，比如准备语句，然后绑定数据，然后执行它们，从而提供更快的处理速度和更高的性能。
在我的应用程序中，有很多CRUD操作使用SQLITE方法，我离开了，因为很难从SQLITE库完全切换到SQLITE包装器。
我的应用程序有后台任务，只使用SQLITE库运行和处理一些web服务调用和大量CRUD操作。
每当我试图用准备好的语句使用SQLITE包装器批量插入时，如果后台任
浏览 3提问于2016-02-20得票数 0
回答已采纳
2回答
在阅读了几篇关于异步的文章之后，我现在理解了以下内容：
作为库作者，您应该始终使用.ConfigureAwait(false)来避免对应用程序使用的SynchronizationContext进行假设。
ConfigureAwait(false)的效果是它将使用线程池上下文，这意味着方法的其余部分可以在任意空闲线程中运行。
不能在lock块的主体中使用“等待”
让我们假设您正在创建一个在非静态类上具有异步API方法的库，并且该类具有一些成员变量，这些成员变量是通过其API方法共享的。如何以确保以线程安全方式访问成员变量的方式编写这些方法？
浏览 0提问于2020-08-18得票数 0
回答已采纳
2回答
背景
我有一个非常大的二进制数据文件(20+ GB)，需要解析、处理数据，然后编写输出。我很少有经验处理如此大量的数据，虽然我在概念化如何处理这些数据时遇到了一些困难，但我确实有一个想法。注意:输入数据包含从IBM大型机检索的许多记录，因此它的格式如下：
每个记录的前4个字节(行/行)是RDW (记录描述符字)。RDW包含记录的长度(包括RDW)。由于RDW，即使文件是一个恒定的字节流，我也知道每个记录的结束位置。我可以将这个二进制文件转换为文本文件，将每两个字节转换为十六进制表示，还可以在记录的末尾包含一个新的行字符，但我担心如果这样翻译一个20+ GB二进制文件会有多大。
因为我想将该文件
浏览 0提问于2018-05-02得票数 3
1回答
不阻塞当前(UI)线程的互斥锁
、、、、
我有一个小任务-我必须创建互斥，使用任务和异步等待，而不是阻塞当前线程(UI线程)。
互斥接口：
Lock() -返回一个任务，只有在互斥变为空闲时才能完成。此任务必须是每个锁的唯一任务，以便不允许每次释放()调用超过一个取消块。释放()-释放互斥。一个也是唯一一个由Lock()返回的任务必须完成。那个互斥必须以这样的方式工作
await mutex.Lock();
// critical code
mutex.Release();
我编写了一些代码(最后参见链接)，但如果简单地描述一下问题的话:我创建了一个类Mutex。在Lock方法中，我做了这样的事情：
await Task.Fact
浏览 4提问于2014-12-07得票数 0
回答已采纳
1回答
在.Net核心中，许多I/O方法都有异步版本，微软建议我们使用它们来提高性能。
但是，正如我们所知道的，异步方法在普通锁中不能正常工作，因为普通锁相对于线程。
例如，在ReadWriteLocker中缺少MemoryCache.when MemoryCache，我需要从数据库读取数据。我现在知道了解决这个问题的两种方法：
".Result".using 将异步数据库查询方法转换为同步，例如“等待”或特殊锁，例如redis锁或一些非官方的AsyncReaderWriteLocker。(我已经找到了一个，但我还没有阅读它的代码，所以我不知道它的细节、成本或新的错误)
所以回到标题，
浏览 0提问于2020-02-18得票数 4
2回答
我有以下问题。我有软件，它可以访问通过USB连接的一块硬件。
在UI中有一些按钮(比如搜索设备等)。
您可以启动一个任务，该任务将锁定资源(USB设备)，并在后台线程上执行耗时的操作。
问题是:如果在需要此资源的GUI中按下一个按钮，则整个UI将被阻塞，直到耗时的后台线程完成为止(由于锁定)。
我有一些想法，如何解决这个问题，但似乎都有很多缺点。
到目前为止，我的想法：
请与Monitor.TryEnter检查是否可以访问资源。##The的缺点是，这要求我更改所有ICommand实现(添加if语句)
创建另一个ICommand实现，它将一个锁作为附加参数，并且只在该锁空闲时执行该方法(
浏览 6提问于2017-02-07得票数 2
1回答
问题:有多个线程访问资源。我需要将它们的数量限制为常数MaxThreads。不能进入线程池的线程应该得到一条错误消息。
解决方案:我开始在下面的算法中使用BlockingCollection<string> pool，但是我看到BlockingCollection需要调用CompleteAdding，但我不能这样做，因为我总是收到传入的线程(为了调试起见，我在下面的示例中硬编码到10 )，考虑web请求。
public class MyTest {
private const int MaxThreads = 3;
private BlockingCollect
浏览 3提问于2014-09-29得票数 1
回答已采纳
以下代码是概念的简化证明。在windows应用程序中，有一个FormClosing事件处理程序来执行一些清理。应用程序启动一些使用Control.Invoke在表单上写入的线程。我知道我可以使用Control.BeginInvoke，但我想更好地了解发生了什么，并找到另一个解决方案。
List<Thread> activeThreadlist;
volatile bool goOnPolling = true;
private void Form1_FormClosing(object sender, FormClosingEventArgs e)
{
go
浏览 4提问于2017-07-06得票数 0
3回答
我试图在一个网站上获得一些内容，该网站由JavaScript提供。所以我用Visibility=Collapsed运行一个WebView。我想等待unitl NavigationCompleted并运行一些JavaScript，然后返回值。 代码看起来像这样： private async void Foo()
{
// Want to get value here
var content = await GetContent();
}
private async Task<string> GetContent()
{
string content;
浏览 32提问于2019-03-10得票数 0
回答已采纳
我正在尝试根据下面的需求创建一个逻辑。
类应该输出到文件messagesCalling 中，类必须保持日志的顺序不阻塞调用线程调用日志必须是线程安全的(将从多个线程调用)
我试过的示例代码如下
Ilogger log = new Logger();
Thread t1 = new Thread(LongRunningTask);
Thread t2 = new Thread(LongRunningTask2);
t1.Start();
t2.Start();
Console.WriteLine("Hello, World!");
async void LongRunni
浏览 9提问于2022-11-16得票数 0
1回答
private static bool Created;
private static System.Threading.Mutex PaintGuard = new System.Threading.Mutex(false, "MonkeysUncleBob", out Created);
//Function that is attached to each pages "LayoutUpdated" call.
private async void AnyPageLayoutUpdated(object sender, o
浏览 1提问于2016-10-12得票数 0
回答已采纳
我有一个系统，所有的数据库操作(SQLite)都必须通过使用工作处理器来运行，所以我可以根据自己的喜好来调度它们。
现在处理器有一个Task<TResult> PostAsync<TResult>(Func<SQLiteConnection, TResult> dbFunc)，但是我所能想到的唯一正常的实现是一个基于堆栈的UI线程工作循环，它利用Task将结果推迟到实际操作被处理的那一刻。
它工作得很好，但是它用SQLite调用阻塞了UI线程。我希望这种情况不会发生，但我能想到的唯一想法是生成一个工作线程来刷新队列，或者让每个操作都是自己的工作线程。我不认为
浏览 1提问于2016-05-15得票数 0
回答已采纳
1回答
目前，我使用这个类(从获得)：
public static class IntSynchronizer
{
private static readonly ConcurrentDictionary<int, object> locks;
static IntSynchronizer()
{
locks = new ConcurrentDictionary<int, object>();
}
public static object GetLock(int id)
{
return loc
浏览 5提问于2022-04-30得票数 0
1回答
信号量和Web套接字
、、、、
我正在努力理解和修正我收到的例外情况：
对于这个SendAsync实例，已经有一个尚未执行的“WebSocket”调用。ReceiveAsync和SendAsync可以同时调用，但最多允许它们同时执行一个未完成的操作。
因此，我有多个线程到一个处理程序，它希望发送特定的客户端特定信息。
当客户端连接时，将通过web套接字连接从客户端的特定连接创建映射到他或她想要流到这些数据的数据。
我的代码看起来是：
foreach (KeyValuePair<socketInfo, data> pair in mapping)
{
//Get th
浏览 4提问于2015-06-18得票数 2
回答已采纳
我是通过异步发出http请求来验证图像urls的。所有的代码与下面的代码都很好，但当我有这么多的图片，我们的防火墙将阻止我的互联网访问，因为这么多线程并发请求。因此，我正在寻找一个解决方案，如何限制并发运行线程的计数。最后，我得到了这个，告诉我要使用，但是我不知何故无法得到这个想法，以及如何实现它？
那是SemaphoreSlim wait还是waitAsnyc (不管怎么说，有什么区别？)在添加任务时，应该在前台吗？我可以像在代码中一样使用linq创建任务列表吗？
为什么使用task.Run？
在执行哪一行之后，线程就开始了吗？在task.run还是task.whenall之后？
浏览 4提问于2015-06-24得票数 2
回答已采纳
我正在使用此代码进行任务恢复和暂停。我需要暂停，因为doSomething()；方法不是每次都能工作，例如，当数据来自web时。所以CPU不会太累，我在很多project.But上使用这个，我不确定这是可靠的还是最好的way.Can，我问你的想法？
static ManualResetEventSlim mre = new ManualResetEventSlim(false);
static void Main(string[] args)
{
mre.Set();
Task.Factory.StartNew(() =>
浏览 3提问于2017-05-25得票数 1
回答已采纳
1回答
我正在创建一个Blazor服务器应用程序，它在加载控件时执行一些async DB访问。
例如，我创建了一个DB locker类，以确保在使用Sqlite时不会同时打开两个事务。目标是控制并行事务的数量-在这里，我将其限制为1。
我在这里面临着一个竞速条件错误，但我不知道实际发生了什么，也不知道为什么我会得到threadSyncCount > 1。
我的DB locker类如下所示：
public static class DBLocker {
static Random rnd = new Random();
static object _lockObject = new
浏览 0提问于2021-04-24得票数 0
我正在寻找一个线程安全的"GetAsync“版本的memoryCache。 我知道有"GetOrCreateAsync“，但在提交一些数据之前，我需要检查它是否存在于缓存中。 我一直在用谷歌搜索，但我还没有找到一个即使在有比赛条件的地方也可以安全使用的ThreadSafe "GetAsync“方法。 有没有一个版本的"GetOrCreateAsync“而不是GET？ 有什么建议吗？ 更新 最后，我使用了一个GetOrAddAsync，如下所示 private readonly SemaphoreSlim locker = new SemaphoreSlim
浏览 64提问于2020-11-07得票数 1
回答已采纳
2回答
C#死锁调用锁定方法
、、、
当我点击rbtn1和rbtn2时，下面的代码会导致死锁。Rbtn2是异步的，当我只多次单击rbtn1时，就可以了。Rbtn2同步，当我只多次单击rbtn2时，也是可以的。但当我把它们混合在一起时，就会出现僵局。为什么会这样呢？
private void rbtn1_Click(object sender, EventArgs e)
{
Task.Run(() => UpdateDisplayLock("a"));
}
private void radButton2_Click(object sender, EventArg
浏览 4提问于2015-06-24得票数 0
回答已采纳
它们的公共接口看起来很相似。声明SemaphoreSlim是一个轻量级的替代方案，不使用Windows内核信号量。指出，SemaphoreSlim的速度要快得多。在什么情况下，SemaphoreSlim比信号量更有意义，反之亦然？
浏览 4提问于2010-11-11得票数 124
回答已采纳
我遇到了一个向.NET核心web服务发送大量请求的问题。我使用SemaphoreSlim来限制并发请求的数量。当我收到10061错误( web服务已拒绝连接)时，我希望回拨同时请求的数量。我目前的想法是取消对SemaphoreSlim的引用，并创建另一个： await this.semaphoreSlim.WaitAsync().ConfigureAwait(false);
counter++;
Uri uri = new Uri($"{api}/{keyProperty}", UriKind.Relative);
string rowVer
浏览 13提问于2020-11-05得票数 0
客户报告了以下代码的问题：
public static async Task<Stream> CreateAsync(string path)
{
StorageFolder folder = await Directory.GetFolderAsync(Path.GetDirectoryName(path));
StorageFile file = await folder.CreateFileAsync(Path.GetFileName(path), CreationCollisionOption.ReplaceE
浏览 5提问于2016-04-22得票数 1
回答已采纳
2回答
因此，我有一个方法，它包含对服务器的异步调用。该代码是从第三方工具调用的，有时会从不同的线程连续几次调用相同的方法，所以我不能影响这一点。
我想确定的是，我的方法只被调用一次，然后，应该忽略另一个调用。
起初，我试图用bool isBusy锁定(锁)，但这并不能让我满意，因为异步请求仍然从第二个线程调用了几次，足够快，可以看到isBusy=true；
然后，我尝试了Monitor
object obj = new object();
Monitor.TryEnter(obj);
try
浏览 0提问于2013-08-20得票数 8
回答已采纳
我对ReaderWriterLockSlim有一些问题。我不明白它是怎么变的。
我的代码：
private async Task LoadIndex()
{
if (!File.Exists(FileName + ".index.txt"))
{
return;
}
_indexLock.EnterWriteLock();// <1>
_index.Clear();
using (TextReader index = File.OpenT
浏览 2提问于2013-10-29得票数 49
回答已采纳
1回答
我试图禁用频繁的用户手势，以便同一命令不会同时执行多次。
private readonly SemaphoreSlim _semaphoreSlim = new SemaphoreSlim(1);
public bool MyCommandCanExecute { get; set; } = true;
public DelegateCommand MyCommand { get; set; }
MyCommand = new DelegateCommand(async () =>
{
await _semaphoreSlim.WaitAsync();
浏览 4提问于2016-08-20得票数 2
1回答
我的程序中有一个异步方法。我需要任务是异步的，因为它发出网络请求，但我不希望它是可重入的。换句话说，如果方法是从代码块A调用的，然后在第一个调用返回之前从代码块B再次调用，我希望第二个调用等到第一个调用完成后再运行。
如果该方法不是异步方法，我将能够使用以下注释完成它: MethodImpl(MethodImplOptions.Synchronized)
但是，编译器不允许将批注附加到异步方法。
我还能做什么？
浏览 0提问于2020-01-22得票数 2
我来自C++世界，所以我非常习惯于锁定线程和互斥保护。假设这个基本函数：
async Task BasicProcess() {
// await time consuming task
}
如何锁定此函数，以便一次只能运行一个BasicProcess？
这就是我想要实现的：
async Task BasicProcess() {
lock (BasicProcessLock) {
// await time consuming task
}
}
浏览 0提问于2013-07-23得票数 10
回答已采纳
在.net 4.0中，添加了几个与线程相关的新类：、和。
Slim版本和较旧的类之间有什么区别，什么时候我应该使用一个而不是另一个？
浏览 0提问于2011-07-20得票数 23
回答已采纳
1回答
这基本上适用于windows 8应用程序，我正在使用这种方法编写一个文件-
static async void WriteDataCords(int numDataCodewords)
{
StorageFolder storageFolder = KnownFolders.DocumentsLibrary;
var storageFile = await storageFolder.GetFileAsync("DataCodeWords.txt");
string data = numDataCodewords.ToString();
浏览 2提问于2013-07-24得票数 0
回答已采纳
1回答
我在用TLSharp。我的目标是向用户发送文件。我创建了服务，并在需要发送文件时发出ASP.NET请求。
它适用于一个文件，但每次在短时间内收到2个或更多请求时，我都会得到一个错误：
System.InvalidOperationException:无效校验和！斯基普。
控制器
[Route("upload/{driveId}")]
public async Task<ActionResult> Upload(string driveId)
{
var ms = new MemoryStream();
var file = service.F
浏览 1提问于2020-02-24得票数 7
1回答
我有一个异步方法，它将通过实体框架从数据库中加载一些信息。
在一种情况下，我想从锁中同步调用该代码。
我需要两个代码副本，一个异步代码，一个非异步代码副本，还是有一种同步调用异步代码的方法？
例如，如下所示：
using System;
using System.Threading.Tasks;
public class Program
{
public static void Main()
{
new Test().Go();
}
}
public class Test
{
private object someLock = new obj
浏览 5提问于2022-01-27得票数 1
我有个问题，我完全理解，但我很难解决。
我有一个使用async/await的事件循环。
我在所有的数据库操作中都使用async/await，所有连续的都是运行事件循环的同一个单线程。
我还需要使用事务，在它的生命周期中，事务将有一些其他的延续。
这么说吧，考虑一下这段代码。
public async Task UpdateItem(int mediaItemId)
{
using (var connection = _dataService.OpenDbConnection())
{
using (var transaction = conn
浏览 0提问于2019-01-30得票数 1
回答已采纳
2回答
我有一个.NET服务，它有2个API调用。下面是我的场景：
当API 1被调用时，服务将向客户端应用程序发送推送通知，并启动ASYNC等待；
客户端应用程序接收推送通知，并立即调用API 2；
一旦API 2被调用，API 2应该通知等待线程API 1，这样API 1将继续执行。
我想获得一些帮助或建议，说明让API 1做异步等待API 2(在另一个线程上)发出信号的正确技术选择。
(理想情况下，只使用.net库，而不是外部库。)
浏览 1提问于2018-11-29得票数 0
回答已采纳
现在看来，在异步代码中，SemaphoreSlim是lock(obj) {}的推荐替代品。我找到了关于如何使用它的建议：
特别是，这个人建议这样做：
//Instantiate a Singleton of the Semaphore with a value of 1. This means that only 1 thread can be granted access at a time.
static SemaphoreSlim semaphoreSlim = new SemaphoreSlim(1,1);
//Asynchronously wait to enter the Sema
浏览 9提问于2020-06-25得票数 2
回答已采纳
我正在学习async/await运算符。我正在尝试解决以下问题： 我有一个设置属性的方法Foo()。它使用来自网络调用的数据执行此操作。Foo()方法可以由多个调用方同时调用。网络调用很慢，所以我对结果进行了缓存，以便多个调用只会获得缓存的数据。 public async Task Foo()
{
string key = "some unique cache key";
if (_cacheService.Get(cacheKey, out int someNumber))
{
MyP
浏览 12提问于2018-12-28得票数 1
回答已采纳
1回答
我想限制线程的最大数量。我该怎么做呢？我知道我可以使用像SetMaximum...if这样的东西，我正在使用ThreadPool。 public async Task ProcessAsync()
{
while (true)
{
Task.Run(Work);
}
}
async Task Work()
{
// some time-consuming job
}
浏览 268提问于2019-12-17得票数 0
摘要
我有一个类，它使用lock提供对私有字段的线程安全访问。但是，出于下面详述的原因，我正在考虑使用SemaphoreSlim来实现线程安全。我知道，如果我用lock (_lock)包围对这个字段的所有访问(就像我目前所做的那样)，我可以保证写到该字段的操作将是原子化的，并且所有线程都会看到最近编写的值()。我想知道是在SemaphoreSlim中得到了这两种保证，还是只得到了原子写的保证。
详细信息
我曾经写过一个接口，用于表示可用于与外部设备通信的服务：
public interface ICommunicationService : IDisposable
{
event Ev
浏览 3提问于2017-10-10得票数 2
2回答
在回顾了这个论坛和其他关于c#多线程的文章之后，我仍然感到困惑，而且在处理这个问题上也有问题。
我希望创建numThreads数量的线程，以便为documentIds中的每个整数执行一个函数。documentIds是一个List<int>，其计数= 100，我想在documentIds中的每个元素上调用RestitchWorker.Restitch。
我现在拥有的是下面，但我很困惑如何保持5个线程运行和循环通过列表100 documentIds.所有的帮助都是感激的。
for (int i = 0; i < documentIds.Count; i++)
{
if (
浏览 1提问于2016-07-06得票数 2
回答已采纳
问题:我有一个HTTP客户端，它向天气预报restAPI发出请求。目前，对气象预报API的并发调用数量有限。对于当前层的最大并发限制是每秒60次并发GET调用。但这一限制在未来可能会改变到100,200甚至更多。
使用更多的信号量会对性能产生影响吗？
码
public class WeatherApiWithConcurrencyAdapter
{
private readonly WeatherForecastApi _weatherForecastApi;
private const int MaxConcurrencyPerSecond = 60;
浏览 2提问于2020-08-27得票数 1
回答已采纳
我在这个类的顶部创建了一个信号量实例。
public static SemaphoreSlim _zReportSemaphore = new SemaphoreSlim(1, 500);
在我的代码中，我需要检索和发送一些数据。
while (_isRunning)
{
try
{
xBsonDocument = null;
//I think its very clear in this line...
MongoDBDAO.xGetInstance().GetZReportData(ref xBsonDocument);
浏览 2提问于2016-03-30得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
即时通信 IM
对象存储活动推荐
腾讯云开发者
