GP Coder

Trang chia sẻ kiến thức lập trình Java

  • Java Core
    • Basic Java
    • OOP
    • Exception Handling
    • Multi-Thread
    • Java I/O
    • Networking
    • Reflection
    • Collection
    • Java 8
  • Design pattern
    • Creational Pattern
    • Structuaral Pattern
    • Behavior Pattern
  • Web Service
    • SOAP
    • REST
  • JPA
  • Java library
    • Report
    • Json
    • Unit Test
  • Message Queue
    • ActiveMQ
    • RabbitMQ
  • All
Trang chủ Java Core Multi-Thread Thực thi nhiều tác vụ cùng lúc như thế nào trong Java?

Thực thi nhiều tác vụ cùng lúc như thế nào trong Java?

Đăng vào 01/02/2019 Được đăng bởi GP Coder 6096 Lượt xem

Trong bài viết về CompletableFuture, chúng ta đã tìm hiểu về cách sử dụng multi-thread trong Java 8. Trong bài này, chúng ta sẽ cùng xem cách sử dụng CompletableFuture trong một bài toán thực tế.

Giả sử chúng ta có một ứng dụng cần thực hiện 2 công việc, tạm gọi là work1 và work2. Có hàng nghìn hàng triệu công việc work1 và khi mỗi công việc work1 hoàn thành sẽ có một danh sách các công việc work2 cần thực hiện. Để tiết kiệm được thời gian, chúng ta sẽ sử dụng Multi-Thread để thực thi công việc work1, khi mỗi công việc work1 hoàn thành, chúng ta cũng sẽ sử dụng Multi-Thread để xử lý kết quả nhận được từ công việc work1 (thực thi công việc work2).

Chương trình của chúng ta như sau:


package com.gpcoder.completable_future;

import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;
import java.util.Random;
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.CompletionStage;
import java.util.concurrent.TimeUnit;
import java.util.stream.Collectors;

/**
 * All level is running with multi-thread
 */
public class ConcurrencyWithCompletableFuture3 {

	public static void main(String[] args) {
		List<String> works = new ArrayList<>();
		works.add("A");
		works.add("B");
		works.add("C");
		works.add("D");
		works.add("E");
		runMultipleAsync(works);
	}

	private static void runMultipleAsync(List<String> works) {
		List<CompletableFuture<List<Void>>> allOfWork1Futures = new ArrayList<>();
		works.stream().forEach(work -> {
			allOfWork1Futures.add(createWork1(work).thenCompose(work1Results -> {
				List<CompletionStage<Void>> allOfWork2Futures = work1Results.stream()
						.map(work1Result -> createWork2(work1Result)).collect(Collectors.toList());
				CompletableFuture<Void> done = CompletableFuture
						.allOf(allOfWork2Futures.toArray(new CompletableFuture[allOfWork2Futures.size()]));
				return done.thenApplyAsync(v -> allOfWork2Futures.stream().map(CompletionStage::toCompletableFuture)
						.map(CompletableFuture::join) // Returns the result value when complete
						.collect(Collectors.toList()));
			}).whenCompleteAsync((result, th) -> {
				// Do something when complete
			}).toCompletableFuture());
		});
		CompletableFuture<Void> done = CompletableFuture
				.allOf(allOfWork1Futures.toArray(new CompletableFuture[allOfWork1Futures.size()]))
				.whenComplete((result, th) -> {
					// Do something when complete
				});
		done.join(); // Returns the result value when complete
	}

	private static CompletionStage<List<String>> createWork1(String str) {
		return CompletableFuture.completedFuture(str).thenApplyAsync(s -> executeWork1(s));
	}

	private static CompletionStage<Void> createWork2(String str) {
		return CompletableFuture.completedFuture(str).thenAcceptAsync(s -> executeWork2(s));
	}

	private static List<String> executeWork1(String _item) {
		waitingForComplete();
		System.out.println("Work" + _item + " -> work1");
		return Arrays.asList(_item + "_item" + 1, _item + "_item" + 2);
	}

	private static void executeWork2(String data) {
		waitingForComplete();
		System.out.println("Work" + data + " -> work2");
	}

	private static void waitingForComplete() {
		try {
			TimeUnit.SECONDS.sleep(random(0, 3));
		} catch (InterruptedException e) {
			e.printStackTrace();
		}
	}

	private static int random(int min, int max) {
		Random r = new Random();
		return r.nextInt((max - min) + 1) + min;
	}
}

Output của chương trình:


WorkB -> work1
WorkC -> work1
WorkB_item1 -> work2
WorkA -> work1
WorkB_item2 -> work2
WorkC_item1 -> work2
WorkD -> work1
WorkE -> work1
WorkA_item1 -> work2
WorkC_item2 -> work2
WorkD_item1 -> work2
WorkD_item2 -> work2
WorkE_item2 -> work2
WorkA_item2 -> work2
WorkE_item1 -> work2

5.0
12
Nếu bạn thấy hay thì hãy chia sẻ bài viết cho mọi người nhé!

Shares

Chuyên mục: Java 8, Multi-Thread Được gắn thẻ: Java 8, Multithreading

Hướng dẫn Java Design Pattern – Dependency Injection
Giới thiệu Google Guice – Dependency injection (DI) framework

Có thể bạn muốn xem:

  • Annotation trong Java 8 (09/07/2018)
  • Lớp Collectors trong Java 8 (18/06/2018)
  • Hướng dẫn tạo và sử dụng ThreadPool trong Java (27/02/2018)
  • Consumer trong Java 8 (28/05/2018)
  • Predicate trong Java 8 (21/05/2018)

Bình luận

bình luận

Tìm kiếm

Bài viết mới

  • Giới thiệu CloudAMQP – Một RabbitMQ server trên Cloud 02/10/2020
  • Kết nối RabbitMQ sử dụng Web STOMP Plugin 19/06/2020
  • Sử dụng publisher confirm trong RabbitMQ 16/06/2020
  • Sử dụng Dead Letter Exchange trong RabbitMQ 13/06/2020
  • Sử dụng Alternate Exchange trong RabbitMQ 10/06/2020

Xem nhiều

  • Hướng dẫn Java Design Pattern – Factory Method (65882 lượt xem)
  • Hướng dẫn Java Design Pattern – Singleton (64371 lượt xem)
  • Lập trình đa luồng trong Java (Java Multi-threading) (60598 lượt xem)
  • Giới thiệu Design Patterns (57268 lượt xem)
  • Giới thiệu về Stream API trong Java 8 (53777 lượt xem)

Lưu trữ

Thẻ đánh dấu

Annotation Authentication Basic Java Behavior Pattern Collection Creational Design Pattern Cấu trúc điều khiển Database Dependency Injection Design pattern Eclipse Exception Executor Service Google Guice Gson Hibernate How to Interceptor IO Jackson Java 8 Java Core JDBC JDK Jersey JMS JPA json JUnit JWT Message Queue Mockito Multithreading OOP Performance PowerMockito RabbitMQ Reflection Report REST SOAP Structuaral Pattern Thread Pool Unit Test Webservice

Liên kết

  • Clean Code
  • JavaTpoint
  • Refactoring Guru
  • Source Making
  • TutorialsPoint
  • W3Schools Online Web Tutorials

Giới thiệu

GP Coder là trang web cá nhân, được thành lập với mục đích lưu trữ, chia sẽ kiến thức đã học và làm việc của tôi. Các bài viết trên trang này chủ yếu về ngôn ngữ Java và các công nghệ có liên quan đến Java như: Spring, JSF, Web Services, Unit Test, Hibernate, SQL, ...
Hi vọng góp được chút ít công sức cho sự phát triển cộng đồng Coder Việt.

Tìm kiếm các bài viết của GP Coder với Google Search

Liên hệ

Các bạn có thể liên hệ với tôi thông qua:
  • Trang liên hệ
  • Linkedin: gpcoder
  • Email: contact@gpcoder.com
  • Skype: ptgiang56it

Follow me

Copyright 2023 © GP Coder · All Rights Reserved · Giới thiệu · Chính sách · Điều khoản · Liên hệ ·

Share

Blogger
Delicious
Digg
Email
Facebook
Facebook messenger
Google
Hacker News
Line
LinkedIn
Mix
Odnoklassniki
PDF
Pinterest
Pocket
Print
Reddit
Renren
Short link
SMS
Skype
Telegram
Tumblr
Twitter
VKontakte
wechat
Weibo
WhatsApp
Xing
Yahoo! Mail

Copy short link

Copy link