我正在使用带有Spring和Hibernate的c3p0 ComboPooledDataSource,我提出的解决方案是一个自定义Datasource类,它接受它的构造函数中的实际Datasource.我将所有责任委托给实际的数据源.我有一个锁定的布尔值,当设置为tr...

我正在使用带有Spring和Hibernate的c3p0 ComboPooledDataSource,我提出的解决方案是一个自定义Datasource类,它接受它的构造函数中的实际Datasource.我将所有责任委托给实际的数据源.我有一个锁定的布尔值,当设置为true时,getConnection()等待,直到锁定为false.
我只是想知道是否有人能看到我的方法存在缺陷或者有更好的选择?谢谢!
public interface LockableDataSource extends DataSource {
public boolean isLocked();
public void setLocked(boolean locked);
}
public class LockableDataSourceImpl implements LockableDataSource{
private DataSource dataSource;
private boolean locked = false;
public LockableDataSourceImpl(DataSource dataSource) {
this.dataSource = dataSource;
}
public Connection getConnection() throws SQLException {
while(locked){
try {
Thread.sleep(500);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
return dataSource.getConnection();
}
public Connection getConnection(String s, String s1) throws SQLException {
while(locked){
try {
Thread.sleep(500);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
return dataSource.getConnection(s, s1);
}
public PrintWriter getLogWriter() throws SQLException {
return dataSource.getLogWriter();
}
public void setLogWriter(PrintWriter printWriter) throws SQLException {
dataSource.setLogWriter(printWriter);
}
public void setLoginTimeout(int i) throws SQLException {
dataSource.setLoginTimeout(i);
}
public int getLoginTimeout() throws SQLException {
return dataSource.getLoginTimeout();
}
public <T> T unwrap(Class<T> tClass) throws SQLException {
return dataSource.unwrap(tClass);
}
public boolean isWrapperFor(Class<?> aClass) throws SQLException {
return dataSource.isWrapperFor(aClass);
}
public boolean isLocked() {
return locked;
}
synchronized public void setLocked(boolean locked) {
this.locked = locked;
}
}
解决方法:
几个缺陷:
>您不同步对标志变量的访问,因此您无法保证其他线程看到其状态.
>在InterruptedException上返回null,这将导致调用代码中难以诊断的异常.
>您正在重新实现已存在的同步原语.
到目前为止,最好的解决方案是在使用数据库时关闭您的应用程序.
如果您确实希望在数据库关闭时挂起应用程序,请查看Semaphore.
本文标题为:我正在恢复数据库,我需要在执行此操作时从我的Java应用程序中锁定任何活动


基础教程推荐
- SpringBoot超详细讲解yaml配置文件 2023-01-24
- SpringBoot同时支持HTTPS与HTTP的实现示例 2023-03-21
- Reactive反应式编程及使用介绍 2022-11-07
- 关于Maven混合配置私有仓库和公共仓库的问题 2023-01-18
- java如何将Object数组转换为指定类型数组 2023-04-17
- @FeignClient注解中属性contextId的使用说明 2023-01-13
- 关于Mybatis与JPA的优缺点说明 2022-12-19
- Java删除String中空格的多种解决方法汇总 2023-01-23
- Java聊天室之实现运行服务器与等待客户端连接 2023-06-17
- Java利用深度搜索解决数独游戏详解 2023-04-16