Code for virtual threads with Spring

pom.xml

@@ -60,6 +60,8 @@
     <module>podman-deployment</module>
     <module>spring-boot-batch</module>
     <module>application-events</module>
+      <module>spring-virtual-threads-example</module>
+      <module>spring-virtual-threads-example/spring-webflux-example</module>
   </modules>
   <name>spring-boot-examples</name>
   <url>https://howtodoinjava.com</url>
@@ -78,10 +80,6 @@
   </properties>
 
   <dependencies>
-    <dependency>
-      <groupId>org.springframework.boot</groupId>
-      <artifactId>spring-boot-starter-web</artifactId>
-    </dependency>
     <dependency>
       <groupId>org.projectlombok</groupId>
       <artifactId>lombok</artifactId>

spring-virtual-threads-example/pom.xml

@@ -0,0 +1,26 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+    <parent>
+        <groupId>com.howtodoinjava.demo</groupId>
+        <artifactId>spring-boot-examples</artifactId>
+        <version>1.0-SNAPSHOT</version>
+    </parent>
+
+    <groupId>com.howtodoinjava.virtual.threads.example</groupId>
+    <artifactId>spring-virtual-threads-example</artifactId>
+    <packaging>pom</packaging>
+    <modules>
+        <module>spring-boot-example</module>
+    </modules>
+
+    <properties>
+        <java.version>21</java.version>
+        <maven.compiler.source>21</maven.compiler.source>
+        <maven.compiler.target>21</maven.compiler.target>
+        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
+    </properties>
+
+</project>

spring-virtual-threads-example/spring-boot-example/pom.xml

@@ -0,0 +1,74 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+    <parent>
+        <groupId>com.howtodoinjava.virtual.threads.example</groupId>
+        <artifactId>spring-virtual-threads-example</artifactId>
+        <version>1.0-SNAPSHOT</version>
+    </parent>
+
+    <artifactId>spring-boot-example</artifactId>
+
+    <properties>
+        <java.version>21</java.version>
+        <maven.compiler.source>21</maven.compiler.source>
+        <maven.compiler.target>21</maven.compiler.target>
+        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
+    </properties>
+
+    <dependencies>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-data-jpa</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.commons</groupId>
+            <artifactId>commons-lang3</artifactId>
+            <version>3.12.0</version>
+        </dependency>
+        <dependency>
+            <groupId>com.h2database</groupId>
+            <artifactId>h2</artifactId>
+            <scope>runtime</scope>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-web</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-test</artifactId>
+            <scope>test</scope>
+        </dependency>
+        <dependency>
+            <groupId>org.projectlombok</groupId>
+            <artifactId>lombok</artifactId>
+            <version>1.18.30</version>
+            <scope>provided</scope>
+        </dependency>
+    </dependencies>
+
+    <build>
+        <plugins>
+            <plugin>
+                <groupId>org.springframework.boot</groupId>
+                <artifactId>spring-boot-maven-plugin</artifactId>
+            </plugin>
+            <plugin>
+                <groupId>org.apache.maven.plugins</groupId>
+                <artifactId>maven-compiler-plugin</artifactId>
+                <configuration>
+                    <compilerArgs>
+                        <arg>--enable-preview</arg>
+                    </compilerArgs>
+                    <source>21</source>
+                    <target>21</target>
+                </configuration>
+
+            </plugin>
+        </plugins>
+    </build>
+
+</project>

spring-virtual-threads-example/spring-boot-example/src/main/java/com/howtodoinjava/virtual/threads/example/Main.java

@@ -0,0 +1,26 @@
+package com.howtodoinjava.virtual.threads.example;
+
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.boot.web.embedded.tomcat.TomcatProtocolHandlerCustomizer;
+import org.springframework.context.annotation.Bean;
+
+import java.util.concurrent.Executors;
+
+@Slf4j
+@SpringBootApplication
+public class Main {
+
+    public static void main(String[] args) {
+        SpringApplication.run(Main.class, args);
+    }
+
+    @Bean
+    public TomcatProtocolHandlerCustomizer<?> protocolHandlerVirtualThreadExecutorCustomizer() {
+        return protocolHandler -> {
+            log.info("Configuring " + protocolHandler + " to use VirtualThreadPerTaskExecutor");
+            protocolHandler.setExecutor(Executors.newVirtualThreadPerTaskExecutor());
+        };
+    }
+}

spring-virtual-threads-example/spring-boot-example/src/main/java/com/howtodoinjava/virtual/threads/example/controller/TestController.java

@@ -0,0 +1,37 @@
+package com.howtodoinjava.virtual.threads.example.controller;
+
+import com.howtodoinjava.virtual.threads.example.model.Product;
+import com.howtodoinjava.virtual.threads.example.repository.ProductRepository;
+import org.apache.commons.lang3.RandomStringUtils;
+import org.apache.commons.lang3.RandomUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import java.util.List;
+
+@RestController
+public class TestController {
+
+    @Autowired
+    ProductRepository productRepository;
+
+    @GetMapping("/thread")
+    public List<Product> checkThread() throws InterruptedException {
+        Thread.sleep(1000);
+        return productRepository.findAll();
+    }
+
+    @PostMapping("/save")
+    public String saveProduct() throws InterruptedException {
+        for(int i = 0; i < 1000; i++){
+            Product product = new Product();
+            product.setProductName(RandomStringUtils.randomAlphanumeric(5));
+            product.setPrice(RandomUtils.nextLong(10,1000));
+            product.setPrice(1L);
+            productRepository.save(product);
+        }
+        return "Success";
+    }
+}

spring-virtual-threads-example/spring-boot-example/src/main/java/com/howtodoinjava/virtual/threads/example/model/Product.java

@@ -0,0 +1,24 @@
+package com.howtodoinjava.virtual.threads.example.model;
+
+import jakarta.persistence.Entity;
+import jakarta.persistence.GeneratedValue;
+import jakarta.persistence.GenerationType;
+import jakarta.persistence.Id;
+import lombok.Getter;
+import lombok.Setter;
+import lombok.ToString;
+
+
+@Getter
+@Setter
+@ToString
+@Entity
+public class Product {
+
+    @Id
+    @GeneratedValue(strategy = GenerationType.IDENTITY)
+    private Long id;
+    private String productName;
+    private Long price;
+
+}

spring-virtual-threads-example/spring-boot-example/src/main/java/com/howtodoinjava/virtual/threads/example/repository/ProductRepository.java

@@ -0,0 +1,7 @@
+package com.howtodoinjava.virtual.threads.example.repository;
+
+import com.howtodoinjava.virtual.threads.example.model.Product;
+import org.springframework.data.jpa.repository.JpaRepository;
+
+public interface ProductRepository extends JpaRepository<Product,Long> {
+}

spring-virtual-threads-example/spring-boot-example/src/main/resources/application.yml

@@ -0,0 +1,21 @@
+spring:
+  datasource:
+    maxIdle: 1
+    url: jdbc:h2:mem:mydb
+    username: sa
+    password: password
+    driverClassName: org.h2.Driver
+    hikari:
+      connection-timeout: 60000
+      maximum-pool-size: 10
+      minimum-idle: 5
+  h2:
+    console:
+      enabled: true
+  jpa:
+    spring.jpa.database-platform: org.hibernate.dialect.H2Dialect
+    generate-ddl: true
+    hibernate:
+      ddl-auto: create
+      format_sql: true
+    show-sql: true

spring-virtual-threads-example/spring-webflux-example/pom.xml

@@ -0,0 +1,58 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+    <parent>
+        <groupId>com.howtodoinjava.demo</groupId>
+        <artifactId>spring-boot-examples</artifactId>
+        <version>1.0-SNAPSHOT</version>
+        <relativePath>../../pom.xml</relativePath>
+    </parent>
+
+    <groupId>com.howtodoinjava.virtual.threads.example</groupId>
+    <artifactId>spring-webflux-example</artifactId>
+
+    <properties>
+        <maven.compiler.source>21</maven.compiler.source>
+        <maven.compiler.target>21</maven.compiler.target>
+        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
+    </properties>
+
+    <dependencies>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-data-r2dbc</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-webflux</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>io.r2dbc</groupId>
+            <artifactId>r2dbc-h2</artifactId>
+            <scope>runtime</scope>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-test</artifactId>
+            <scope>test</scope>
+        </dependency>
+        <dependency>
+            <groupId>io.projectreactor</groupId>
+            <artifactId>reactor-test</artifactId>
+            <scope>test</scope>
+        </dependency>
+        <dependency>
+            <groupId>org.projectlombok</groupId>
+            <artifactId>lombok</artifactId>
+            <version>1.18.30</version>
+            <scope>provided</scope>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.commons</groupId>
+            <artifactId>commons-lang3</artifactId>
+        </dependency>
+    </dependencies>
+
+</project>

spring-virtual-threads-example/spring-webflux-example/src/main/java/com/howtodoinjava/virtual/threads/example/Main.java

@@ -0,0 +1,19 @@
+package com.howtodoinjava.virtual.threads.example;
+
+import io.r2dbc.spi.ConnectionFactory;
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.context.annotation.Bean;
+import org.springframework.core.io.ClassPathResource;
+import org.springframework.r2dbc.connection.init.ConnectionFactoryInitializer;
+import org.springframework.r2dbc.connection.init.ResourceDatabasePopulator;
+import org.springframework.web.reactive.config.EnableWebFlux;
+
+@EnableWebFlux
+@SpringBootApplication
+public class Main {
+    public static void main(String[] args) {
+        SpringApplication.run(Main.class, args);
+    }
+
+}

spring-virtual-threads-example/spring-webflux-example/src/main/java/com/howtodoinjava/virtual/threads/example/webflux/controller/WebfluxHomeController.java

@@ -0,0 +1,40 @@
+package com.howtodoinjava.virtual.threads.example.webflux.controller;
+
+import com.howtodoinjava.virtual.threads.example.webflux.model.Product;
+import com.howtodoinjava.virtual.threads.example.webflux.repository.ProductRepo;
+import org.apache.commons.lang3.RandomStringUtils;
+import org.apache.commons.lang3.RandomUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+import reactor.core.publisher.Flux;
+import reactor.core.publisher.Mono;
+
+@RestController
+@RequestMapping("/webflux")
+public class WebfluxHomeController {
+
+    @Autowired
+    ProductRepo productRepository;
+
+    @GetMapping("/thread")
+    public Flux<Product> webfluxThreadProducts() throws InterruptedException {
+        Thread.sleep(1000);
+        return productRepository.findAll();
+    }
+
+    @PostMapping("/save")
+    public String webfluxSaveProduct() throws InterruptedException {
+        for(int i = 0; i < 1000; i++){
+            Product product = new Product();
+            product.setProductName(RandomStringUtils.randomAlphanumeric(5));
+            product.setPrice(RandomUtils.nextLong(10,1000));
+            product.setPrice(1L);
+            Mono<Product> savedData = productRepository.save(product);
+            System.out.println(savedData.toString());
+        }
+        return "Success";
+    }
+}

spring-virtual-threads-example/spring-webflux-example/src/main/java/com/howtodoinjava/virtual/threads/example/webflux/model/Product.java

@@ -0,0 +1,21 @@
+package com.howtodoinjava.virtual.threads.example.webflux.model;
+
+
+import lombok.*;
+import org.springframework.data.annotation.Id;
+import org.springframework.data.relational.core.mapping.Table;
+
+
+@Getter
+@Setter
+@AllArgsConstructor
+@NoArgsConstructor
+@Table("product")
+public class Product {
+
+    @Id
+    private Long id;
+    private String productName;
+    private Long price;
+
+}