java springboot 使用线程池向mysql存储单条数据 代码
时间: 2024-02-16 13:00:13 浏览: 93
springboot+quartz +mysql 核心代码
下面是一个使用线程池向MySQL存储单条数据的Java Spring Boot代码示例:
```java
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import javax.annotation.PostConstruct;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Component;
@Component
public class DataWriter {
@Autowired
private JdbcTemplate jdbcTemplate;
private ExecutorService executorService;
@PostConstruct
public void init() {
executorService = Executors.newFixedThreadPool(10);
}
public void writeData(Data data) {
executorService.submit(() -> {
jdbcTemplate.update("INSERT INTO table_name (column1, column2, column3) VALUES (?, ?, ?)",
data.getColumn1(), data.getColumn2(), data.getColumn3());
});
}
}
```
这个代码片段使用了Java的ExecutorService类创建一个固定大小(10个)的线程池,然后在writeData方法中使用线程池提交一个任务,将数据插入到MySQL数据库中。从而实现了异步写入数据的功能。
阅读全文