hey just a quick question since i m not to firm with corouti kotlinlang #announcements

Channels

kotlin-foundation

compose-android

ohio-kotlin-users

kotlin-by-example

sofl-user-group

kotlin-multiplatform-contest

tricity-kotlin-user-group

kotlin-in-action

android-databinding

cincinnati-user-group

fluid-libraries

codemash-precompiler

kotlingforbeginners

jhipster-kotlin

prozis-android-backup

realworldkotlin

graviton-browser

spring-security

domain-driven-design

connect-audit-events

swiss-user-group

effectivekotlin

refactoring-to-kotlin

russian-kotlinasfirst

androidgithubprojects

introduce-yourself

pocketgitclient

effective-kotlin

algolialibraries

lambdaworld_cadiz

intellij-tricks

kotlin-pakistan

navigation-architecture-component

strife-discord-lib

machinelearningbawas

leedskotlinusergroup

stayhungrystayfoolish

kotest-contributors

practical-functional-programming

swagger-gradle-codegen

100daysofkotlin

kotlinultimatechallenge

pattern-matching

kotlinforbeginners

competitive-programming

compose-ui-showcase

competitivecoding

kotlin-data-storage

skia-wasm-interop-temp

java-to-kotlin-refactoring

event21-community-content

androidx-xprocessing

embedded-kotlin

fb-internal-demo

image-processing

myndocs-oauth2-server

kotlintest-devs

beepiz-libraries

kotlinprogrammers

cscenter-course-2016

k2-early-adopters

intellij-plugins

language-proposals

library-development

refreshversions

language-evolution

kotlinx-datetime

framework-elide

compose-desktop

jvm-ir-backend-feedback

android-architecture

100daysofkotlin-2021

github-workflows-kt

python-contributors

squarelibraries

arrow-contributors

codingconventions

getting-started

Title

s

silas.schwarz

11/15/2018, 9:23 AM

hey just a quick question since i'm not to firm with coroutines yet. how would you tackle something that you want to do in parallel (network request) but need to assure that there are never more than 4 requests in parallel (threadpoolexecutor but in coroutines). i've seen that so can assign work to pools (CommonPool) etc but can you create your own pool and define it's parallelism ?! thx 😙

g

gildor

11/15/2018, 9:24 AM

Better to use worker pool pattern for that

using CommonPool, or any other custom dispatcher will not work for any async API that doesn’t block threads or has own thread pool (like every http client with async api)

There is an issue to provide built in implementation of working pool https://github.com/Kotlin/kotlinx.coroutines/issues/172

Also, see this talk by Roman, there is a part about limiting concurrency that explains this idea and pattern:

https://youtu.be/a3agLJQ6vt8?t=1112▾

But in some cases, like for example in case HTTP client, you have some APIs to limit concurrency on library level, some http client allow to do that, also providing more smart limiting, based on host, network state etc

but approach with working pool is universal solution ffor this

s

silas.schwarz

11/15/2018, 9:30 AM

thank you very much for all the input!

🙇‍♂️

g

gildor

11/15/2018, 9:32 AM

👍

s

silas.schwarz

11/15/2018, 9:33 AM

i used rxkotlin and okhttp which makes it easy to enforce only 4 in parallel but i was trying to build something in plain kotlin and coroutines as an alternative. thanks

g

gildor

11/15/2018, 9:33 AM

okhttp has built in mechanism to limit concurrency

See https://square.github.io/okhttp/3.x/okhttp/okhttp3/Dispatcher.html

4 Views

#announcements Join Slack