jjzjj

concurrent-queue

全部标签

postgresql - Postgres : Optimising concurrent same row updates

问题我正在使用PostgreSQLv10+golang,我认为这是一个非常常见的SQL问题:我有一个“计数器”表,它有一个current_value和一个max_value整数列。严格来说,一旦current_value>=max_value,我想放弃请求。我有几个Kubernetespod,每个API调用可能会将“计数器”表中同一行(在最坏情况下)的current_value增加1(可以被认为是分布式主机对同一数据库的并发更新)。在我当前和天真的实现中,对同一行的多个更新自然会相互阻塞(如果重要的话,隔离级别是“已提交读”)。在最坏的情况下,我每秒有大约10多个请求会更新同一行。这会

concurrency - 为什么并发写入的boolean值设置为false后还是true?

我正在用Go编写哲学家用餐解决方案。我的解决方案很简单:检查两个fork是否可用。如果是这样,请同时选择两者。如果不是,请保留两者。但是,我遇到了一个奇怪的并发错误,即使在明确设置为false之后,fork的可用性仍然是true。我的Fork声明如下:typeForkstruct{musync.Mutexavailbool}func(f*Fork)PickUp()bool{f.mu.Lock()iff.avail==false{f.mu.Unlock()returnfalse}f.avail=falsefmt.Println("setfalse")f.mu.Unlock()return

concurrency - 这个webapp代码需要同步吗?

我目前正在学习Go,这是我正在编写的网络应用程序的代码:funcinit(){db,err:=sql.Open("mysql","master:123456@/shopping_list")iferr!=nil{panic(err.Error())}http.HandleFunc("/sql",func(whttp.ResponseWriter,r*http.Request){sqlHandler(w,r,db)})}sqlHandler()从shopping_list中的表中读取一条记录,对其进行编辑,然后更新记录。现在据我了解,每个请求都在一个单独的goroutine上运行,并且m

concurrency - Go Memory Model文档中给出的这个例子失败的原因是什么?

在Go内存模型文档中http://golang.org/ref/mem它给出了以下示例:varastringvardoneboolfuncsetup(){a="hello,world"done=true}funcmain(){gosetup()for!done{}print(a)}然后它说这个例子的以下内容。"thereisnoguaranteethatthewritetodonewilleverbeobservedbymain,sincetherearenosynchronizationeventsbetweenthetwothreads.Theloopinmainisnotguar

concurrency - 使用并发的 Golang 流水线

Go新手。我正在尝试编写一个“流水线”,其中多个函数像worker一样工作,并在流水线中将一些数据结构传递给彼此,每个函数都对数据结构做一些事情。typeorderStructstruct{orderNum,capacityintorderCodeuint64box[9]int}funcposition0(inchanorderStruct){order:=>63==1){order.box[order.capacity]=1order.capacity+=1}fmt.Println("fillingbox{",order.orderNum,order.orderCode,order.

concurrency - 如何将多个 goroutine 同步到所选 goroutine 的终止(即 Thread.join())

我在上一个问题中问过这个问题,但有些人觉得我最初的问题不够详细(“为什么你会想要一个定时条件等待??”)所以这里有一个更具体的问题。我有一个goroutine正在运行,称之为服务器。它已经启动,将执行一段时间,然后执行它的操作。然后,它将退出,因为它已完成。在它执行期间,一些大量的其他goroutines开始。如果您愿意,可以将它们称为“客户端”线程。他们运行步骤A和步骤B。然后,他们必须等待“服务器”goroutine完成一段指定的时间,如果“服务器未完成”则以状态退出,如果完成则运行步骤C。(请不要告诉我如何重构此工作流。这是假设的,是给定的。无法更改。)一个正常、明智的方法是让服

windows - 在 gtk_widget_queue_draw 中 Windows 7 下 GTK 中的内存泄漏

下面的GTK程序:#includeGtkVBox*vbox;GtkWindow*win;gbooleanTimer(gpointeruser_data){gtk_widget_queue_draw(GTK_WIDGET(vbox));return1;}intmain(intargc,char**argv){gtk_init(&argc,&argv);win=(GtkWindow*)gtk_window_new(GTK_WINDOW_TOPLEVEL);vbox=(GtkVBox*)gtk_vbox_new(TRUE,1);gtk_container_add(GTK_CONTAINER(

c# - 启用具有并发性的 Queue<T>

我有一个以前的question我已经提供了我的解决方案;但是,我无权访问ConcurrentQueue因为我在.Net3.5上。我需要Queue允许并发。我读了这个question如果一个项目不在队列中并且线程方法试图使一个项目出队,并且似乎会出现问题。我现在的任务是确定我是否可以派生我自己的并发Queue类。这是我想出的:publicsealedclassConcurrentQueue:Queue{publiceventEventHandlerTableQueued;privateICollectionque;newpublicvoidEnqueue(DataTableTable){

c# - .NET 4.0 System.Collections.Concurrent 集合在 .NET 3.0 SynchronizedCollection 的功能中添加了什么?

.NET4.0引入了System.Collections.Concurrent命名空间:"TheSystem.Collections.Concurrentnamespaceprovidesseveralthread-safecollectionclassesthatshouldbeusedinplaceofthecorrespondingtypesintheSystem.CollectionsandSystem.Collections.Genericnamespaceswhenevermultiplethreadsareaccessingthecollectionconcurrentl

c# - 为什么 Stack<T> 和 Queue<T> 没有 Capacity 属性而 List<T> 有?

Capacity属性在List中是否比在其他集合(如Stack和Queue)中更有用?还是有其他方法可以获取Stack或Queue的容量? 最佳答案 我认为List具有Capacity属性而Stack和Queue没有的原因是这些类型的正常用法是不同的。对于List,用大量值填充它是相当常见的,甚至在它创建一段时间后也是如此。提供Capacity属性(和构造函数参数)有助于减少将大量项目添加到列表时将完成的重新分配的数量。Stack和Queue另一方面,它们不会立即添加大量项目已创建。据推测,Microsoft认为不值得添加Capac