Maison >Java >javaDidacticiel >Un guide complet pour maîtriser les coroutines Kotlin
Les coroutines simplifient la programmation asynchrone en la rendant plus lisible et efficace. Considérez les fils de discussion comme des voitures individuelles sur une autoroute, chacune occupant de l'espace et des ressources. En revanche, les coroutines sont comme le covoiturage : plusieurs tâches partageant efficacement les ressources.
Trois avantages principaux distinguent les coroutines :
Pour démarrer avec les coroutines dans votre projet Android, ajoutez ces dépendances à votre fichier build.gradle :
dependencies { implementation "org.jetbrains.kotlinx:kotlinx-coroutines-android:1.7.1" implementation "org.jetbrains.kotlinx:kotlinx-coroutines-core:1.7.1" }
Les constructeurs de coroutines constituent la base de la création et du lancement de coroutines. Explorons chaque type avec des exemples pratiques :
Lancement
class WeatherService { fun updateWeather() { lifecycleScope.launch { // Simulating weather API call val weather = fetchWeatherData() updateUI(weather) } } private suspend fun fetchWeatherData(): Weather { delay(1000) // Simulate network delay return Weather(temperature = 25, condition = "Sunny") } }
Asynchrone
class StockPortfolio { suspend fun fetchPortfolioValue() { val stocksDeferred = async { fetchStockPrices() } val cryptoDeferred = async { fetchCryptoPrices() } // Wait for both results val totalValue = stocksDeferred.await() + cryptoDeferred.await() println("Portfolio value: $totalValue") } }
Comprendre les portées et les contextes est crucial pour une bonne gestion des coroutines. Examinons différents types de portée :
LifecycleScope
class NewsActivity : AppCompatActivity() { override fun onCreate(savedInstanceState: Bundle?) { super.onCreate(savedInstanceState) lifecycleScope.launch { val news = newsRepository.fetchLatestNews() newsAdapter.submitList(news) } } }
ViewModelScope
class UserViewModel : ViewModel() { private val _userData = MutableLiveData<User>() fun loadUserData() { viewModelScope.launch { try { val user = userRepository.fetchUserDetails() _userData.value = user } catch (e: Exception) { // Handle error } } } }
Les répartiteurs déterminent sur quelles coroutines de thread s'exécutent. Voici comment utiliser efficacement différents répartiteurs :
class ImageProcessor { fun processImage(bitmap: Bitmap) { lifecycleScope.launch(Dispatchers.Default) { // CPU-intensive image processing val processed = applyFilters(bitmap) withContext(Dispatchers.Main) { // Update UI with processed image imageView.setImageBitmap(processed) } } } suspend fun downloadImage(url: String) { withContext(Dispatchers.IO) { // Network operation to download image val response = imageApi.fetchImage(url) saveToDatabase(response) } }
Une bonne gestion des erreurs est essentielle dans les coroutines. Voici comment le mettre en œuvre efficacement :
class DataManager { private val exceptionHandler = CoroutineExceptionHandler { _, exception -> println("Caught $exception") } fun fetchData() { lifecycleScope.launch(exceptionHandler) { try { val result = riskyOperation() processResult(result) } catch (e: NetworkException) { showError("Network error occurred") } catch (e: DatabaseException) { showError("Database error occurred") } } } }
Flow est parfait pour gérer les flux de données, tandis que StateFlow est idéal pour gérer l'état de l'interface utilisateur :
class SearchViewModel : ViewModel() { private val _searchResults = MutableStateFlow<List<SearchResult>>(emptyList()) val searchResults: StateFlow<List<SearchResult>> = _searchResults.asStateFlow() fun search(query: String) { viewModelScope.launch { searchRepository.getSearchResults(query) .flowOn(Dispatchers.IO) .catch { e -> // Handle errors } .collect { results -> _searchResults.value = results } } } }
La concurrence structurée permet de gérer efficacement les coroutines associées :
class OrderProcessor { suspend fun processOrder(orderId: String) = coroutineScope { val orderDeferred = async { fetchOrderDetails(orderId) } val inventoryDeferred = async { checkInventory(orderId) } val paymentDeferred = async { processPayment(orderId) } try { val order = orderDeferred.await() val inventory = inventoryDeferred.await() val payment = paymentDeferred.await() finalizeOrder(order, inventory, payment) } catch (e: Exception) { // If any operation fails, all others are automatically cancelled throw OrderProcessingException("Failed to process order", e) } } }
Les coroutines Kotlin offrent un moyen puissant mais intuitif de gérer les opérations asynchrones dans le développement Android. En comprenant ces concepts et modèles de base, vous pouvez écrire des applications plus efficaces, plus faciles à maintenir et plus robustes. N'oubliez pas de toujours considérer la portée, le répartiteur et les stratégies de gestion des erreurs appropriées pour votre cas d'utilisation spécifique.
La clé pour maîtriser les coroutines est la pratique : commencez à les implémenter dans vos projets, expérimentez différents modèles et créez progressivement des implémentations plus complexes à mesure que votre compréhension grandit.
Écrit à l'origine ici
Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!