springboot多线程使用

在Spring Boot中使用多线程可以通过Java的Thread类或者使用Spring提供的线程池来实现。下面我会给你两个示例来说明。

使用Java的Thread类:

import org.springframework.stereotype.Component;

@Component
public class MyThread implements Runnable {

    @Override
    public void run() {
        // 在这里编写你的多线程代码逻辑
        System.out.println("Hello from thread!");
    }
}

然后，在你的业务逻辑中调用这个线程：

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;

@RestController
public class MyController {

    @Autowired
    private MyThread myThread;

    @GetMapping("/startThread")
    public String startThread() {
        Thread thread = new Thread(myThread);
        thread.start();
        return "Thread started";
    }
}

当你访问`/startThread`时，将会启动一个新的线程并执行`MyThread`中的`run`方法。

使用Spring提供的线程池:
首先，在你的Spring Boot配置文件中配置线程池的相关属性：

spring.task.execution.pool.core-size=5
spring.task.execution.pool.max-size=10
spring.task.execution.pool.queue-capacity=1000

然后，创建一个异步方法：

import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Component;

@Component
public class MyService {

    @Async
    public void processAsync() {
        // 在这里编写你的多线程代码逻辑
        System.out.println("Hello from asynchronous method!");
    }
}

最后，在你的业务逻辑中调用这个异步方法：

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;

@RestController
public class MyController {

    @Autowired
    private MyService myService;

    @GetMapping("/startAsync")
    public String startAsync() {
        myService.processAsync();
        return "Asynchronous method started";
    }
}

当你访问`/startAsync`时，将会异步执行`MyService`中的`processAsync`方法。

这两种方式都可以在Spring Boot中实现多线程，具体选择哪种方式取决于你的需求和场景。希望对你有帮助！