Modern concurrency tools including agents, futures, promises, thread pools, supervisors, and more. Inspired by Erlang, Clojure, Scala, Go, Java, JavaScript, and classic concurrency patterns.
Thread#kill on it.The thread seems to be alive afterwards though.
Using https://travis-ci.org/ruby-concurrency/concurrent-ruby/jobs/659471195
Rubinius
osx, Xcode: xcode8 Ruby: rbx-3.107
Hey. I have a Javascript Promise/A+ background. Trying to understand the API reference, cause it's hard to find any examples for the library usage in the Net.
The question is how to create a pending Promise?
I use multiple constructor functions like: Concurrent::Promises.future and Concurrent::Promises.zip_futures (aka Promise.all) and both start to invoke resolver immediately.
I want to be able to resolve explicitly with the wait/result/value method.
Instead, now I need to add an unneeded condition like this:result.wait unless result.fulfilled?
Thanks.
@Hyperc0der_twitter here's a GitHub search that has plenty of code examples:
I do though think most usages are executing the promise and resolving.
Channel.go
Concurrent::Channel.go do
loop do
Concurrent::Channel.select do |s|
s.take(somechannel) {
#do something
}
s.take(otherchannel) {
# dosomething
}
end
end
end- Have you verified the loop is broken? For example, by puts-ing a message after the loop-end. I don't see an block-breaking return or throw in what you posted.
- Concurrent ruby typically runs things on a global thread pool that will manage, reuse and recycle threads on its own. So if you're confident that the thread isn't doing any work, it shouldn't need to be actively killed.
Hi all. I have a problem when converting a js function to ruby, using concurrent-ruby gem.
JS code:
async function test_js(redis) {
const arrPromises = [];
arrPromises.push(
redis.delAsync("key1")
);
arrPromises.push(
redis.delAsync("key2")
);
await Promise.all(arrPromisses);
logger.info('remove success');
}Ruby code:
promises = []
promises << Concurrent::Promise.new do
redis.del("key1")
end
promises << Concurrent::Promise.new do
redis.del("key2")
end
promises.each { |j| j.execute }
Concurrent::Promise.all?(*promises).
then{|result| puts "remove success" }.
rescue { |reason| puts reason }.executeI'm quite confused cause Promise.all(arrPromisses) will execute all promisses in this array at the same time, while promises.each { |j| j.execute } delay a litle bit cause they're in loop.
Is there any better way to convert this js function to ruby code?
Thank you (bow)
Concurrent::Promises.zip(*tasks).value!.flatten.compact.uniq
def tasks
files.map do |original_file|
Concurrent::Promises.future(original_file) { |file| process_file(file) }.rescue do |exception|
Rails.logger.error(exception)
Bugsnag.notify(exception)
[]
end
end
end
def process_file(file)
ProcessFile.perform(file: file, dir: dir, declaration_uuid: declaration_uuid)
endPromises api to provide better support for the exact thing you are trying to achieve.
