Skip to content
#

concurrency

Here are 1,840 public repositories matching this topic...

ava
moon0326
moon0326 commented Aug 29, 2018

Please answer these questions before submitting your issue. Thanks!

  1. What did you do? If possible, provide a recipe for reproducing the error.

read Chinese and English documentation

  1. What did you expect to see?

I expected to find best practice for production usage

  1. What did you see instead?

nothing

  1. What version of Swoole are you using (php --ri swoole)?

latest.

yew
akka
skrap
skrap commented Feb 4, 2020

Issue description

In writing rust zmq bindings for tokio, the question came up about when zmq_send and zmq_recv might return EAGAIN when passed the ZMQ_DONTWAIT flag in a multipart message. The implication of the high water mark documentation is that it will only return EAGAIN on the first part of the multipart message, but I couldn't find it explicitly stated anywhere that this

mandreyel
mandreyel commented Feb 17, 2019

Not sure if this should be an issue but I was reading the docs and then followed the link to the example's code on github and noticed that they differed. Which is considered more up-to-date (and thus the best practice)?

mikehearn
mikehearn commented Apr 25, 2016

I have some code that is throwing an exception in a post-park action (i.e. inside the handler passed to parkAndSerialize). Quasar silently eats this exception in RunnableFiberTask.onException(). It's really confusing to have the framework eat exceptions without any kind of logging or error printing at all.

I suggest changing this code such that if the exception isn't handled here, it's either re-

Qiao-Jin
Qiao-Jin commented Apr 21, 2020

I'm new in Akka and trying to self-define a dispatcher in my code. But there are so few akka dotnet examples available, and most of them are using config files..
Could I create a dispatcher in code, i.e., like the follows:

public Dispatcher myDispatcher = new Dispatcher(new DispatcherConfigurator(ConfigurationFactory.ParseString(@"akka.actor.default-dispatcher { type = ""Akka.Dispatch.TaskDisp

Zyl9393
Zyl9393 commented Jul 13, 2019

Gamma correction is among the things most often done wrong by graphics programming novices. It's almost as bad as missing scene-related color transforms and linear volume sliders in the average video game. The code example in the readme should definitely mention to adjust.Gamma(img, 1/2.2) before doing any color mixing and adjust.Gamma(img, 2.2) before saving back to file (for as long as _bild

tinco
tinco commented Oct 15, 2019

Hi, I'm not sure if more platforms are interesting to you, but I've made a slightly more complete implementation of padding a struct to the cache line size here:

https://github.com/tinco/cache_line_size

I got the information on the cache line sizes from the Go compiler repository, so I'm pretty sure these are correct for all platforms Go runs on, which is a whole bunch.

ceki
ceki commented Nov 19, 2019

It's not easy to understand what the code generators under jctools-build are supposed to do. I think one or two phases documenting their goal would be useful.

I am proposing to document these classes:

  • JavaParsingAtomicArrayQueueGenerator.java
  • JavaParsingAtomicLinkedQueueGenerator.java
  • JavaParsingAtomicQueueGenerator.java
zio
iravid
iravid commented Apr 30, 2020

The only variant implemented currently fails the stream with an interruption. This is arguably unexpected because we could have just ended the stream.

We should implement variants of timeout that mirror the ones on ZIO:

  • timeout(Duration) should end the stream when a pull times out
  • timeoutErr(e: E) should fail the stream with E when a pull times out
  • timeoutTo(ZStream) should swi

Improve this page

Add a description, image, and links to the concurrency topic page so that developers can more easily learn about it.

Curate this topic

Add this topic to your repo

To associate your repository with the concurrency topic, visit your repo's landing page and select "manage topics."

Learn more

You can’t perform that action at this time.