|
|
|
@ -21,11 +21,16 @@ import java.util.concurrent.Executors;
|
|
|
|
|
*/ |
|
|
|
|
public class VcsService { |
|
|
|
|
|
|
|
|
|
private static final String RESTORE = "VcsRestore"; |
|
|
|
|
private static final String DELETE = "VcsDelete"; |
|
|
|
|
private static final String UPDATE = "VcsUpdate"; |
|
|
|
|
private static final String SERVICE = "VcsService"; |
|
|
|
|
private static final VcsService INSTANCE = new VcsService(); |
|
|
|
|
|
|
|
|
|
private static final ExecutorService executorService = Executors.newFixedThreadPool(5, new NamedThreadFactory(SERVICE)); |
|
|
|
|
|
|
|
|
|
/** |
|
|
|
|
* 获取单例 |
|
|
|
|
* |
|
|
|
|
* @return |
|
|
|
|
*/ |
|
|
|
|
public static VcsService getInstance() { |
|
|
|
|
return INSTANCE; |
|
|
|
|
} |
|
|
|
@ -53,10 +58,8 @@ public class VcsService {
|
|
|
|
|
* @param vcsEntities |
|
|
|
|
*/ |
|
|
|
|
public void doRestore(List<VcsEntity> vcsEntities) { |
|
|
|
|
ExecutorService executorService = null; |
|
|
|
|
try { |
|
|
|
|
executorService = Executors.newSingleThreadExecutor(new NamedThreadFactory(RESTORE)); |
|
|
|
|
executorService.submit(new Runnable() { |
|
|
|
|
executorService.execute(new Runnable() { |
|
|
|
|
@Override |
|
|
|
|
public void run() { |
|
|
|
|
VcsOperator operator = WorkContext.getCurrent().get(VcsOperator.class); |
|
|
|
@ -68,10 +71,6 @@ public class VcsService {
|
|
|
|
|
}); |
|
|
|
|
} catch (Exception e) { |
|
|
|
|
FineLoggerFactory.getLogger().error(e.getMessage(), e); |
|
|
|
|
} finally { |
|
|
|
|
if (executorService != null) { |
|
|
|
|
executorService.shutdown(); |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
|
|
|
|
@ -82,10 +81,8 @@ public class VcsService {
|
|
|
|
|
* @param vcsEntities |
|
|
|
|
*/ |
|
|
|
|
public void doDelete(List<VcsEntity> vcsEntities, boolean all) { |
|
|
|
|
ExecutorService executorService = null; |
|
|
|
|
try { |
|
|
|
|
executorService = Executors.newSingleThreadExecutor(new NamedThreadFactory(DELETE)); |
|
|
|
|
executorService.submit(new Runnable() { |
|
|
|
|
executorService.execute(new Runnable() { |
|
|
|
|
@Override |
|
|
|
|
public void run() { |
|
|
|
|
VcsOperator operator = WorkContext.getCurrent().get(VcsOperator.class); |
|
|
|
@ -101,10 +98,6 @@ public class VcsService {
|
|
|
|
|
}); |
|
|
|
|
} catch (Exception e) { |
|
|
|
|
FineLoggerFactory.getLogger().error(e.getMessage(), e); |
|
|
|
|
} finally { |
|
|
|
|
if (executorService != null) { |
|
|
|
|
executorService.shutdown(); |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
|
|
|
|
@ -114,10 +107,8 @@ public class VcsService {
|
|
|
|
|
* @param entity VcsEntity |
|
|
|
|
*/ |
|
|
|
|
public void deleteEntity(VcsEntity entity) { |
|
|
|
|
ExecutorService executorService = null; |
|
|
|
|
try { |
|
|
|
|
executorService = Executors.newSingleThreadExecutor(new NamedThreadFactory(DELETE)); |
|
|
|
|
executorService.submit(new Runnable() { |
|
|
|
|
executorService.execute(new Runnable() { |
|
|
|
|
@Override |
|
|
|
|
public void run() { |
|
|
|
|
VcsOperator vcsOperator = WorkContext.getCurrent().get(VcsOperator.class); |
|
|
|
@ -127,10 +118,6 @@ public class VcsService {
|
|
|
|
|
}); |
|
|
|
|
} catch (Exception e) { |
|
|
|
|
FineLoggerFactory.getLogger().error(e.getMessage(), e); |
|
|
|
|
} finally { |
|
|
|
|
if (executorService != null) { |
|
|
|
|
executorService.shutdown(); |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
|
|
|
|
@ -141,10 +128,8 @@ public class VcsService {
|
|
|
|
|
* @param version 版本号 |
|
|
|
|
*/ |
|
|
|
|
public void deleteEntity(String fileName, int version) { |
|
|
|
|
ExecutorService executorService = null; |
|
|
|
|
try { |
|
|
|
|
executorService = Executors.newSingleThreadExecutor(new NamedThreadFactory(DELETE)); |
|
|
|
|
executorService.submit(new Runnable() { |
|
|
|
|
executorService.execute(new Runnable() { |
|
|
|
|
@Override |
|
|
|
|
public void run() { |
|
|
|
|
VcsOperator vcsOperator = WorkContext.getCurrent().get(VcsOperator.class); |
|
|
|
@ -153,10 +138,6 @@ public class VcsService {
|
|
|
|
|
}); |
|
|
|
|
} catch (Exception e) { |
|
|
|
|
FineLoggerFactory.getLogger().error(e.getMessage(), e); |
|
|
|
|
} finally { |
|
|
|
|
if (executorService != null) { |
|
|
|
|
executorService.shutdown(); |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
|
|
|
|
@ -166,10 +147,8 @@ public class VcsService {
|
|
|
|
|
* @param entity 版本 |
|
|
|
|
*/ |
|
|
|
|
public void updateEntityAnnotation(VcsEntity entity) { |
|
|
|
|
ExecutorService executorService = null; |
|
|
|
|
try { |
|
|
|
|
executorService = Executors.newSingleThreadExecutor(new NamedThreadFactory(UPDATE)); |
|
|
|
|
executorService.submit(new Runnable() { |
|
|
|
|
executorService.execute(new Runnable() { |
|
|
|
|
@Override |
|
|
|
|
public void run() { |
|
|
|
|
VcsOperator vcsOperator = WorkContext.getCurrent().get(VcsOperator.class); |
|
|
|
@ -178,10 +157,6 @@ public class VcsService {
|
|
|
|
|
}); |
|
|
|
|
} catch (Exception e) { |
|
|
|
|
FineLoggerFactory.getLogger().error(e.getMessage(), e); |
|
|
|
|
} finally { |
|
|
|
|
if (executorService != null) { |
|
|
|
|
executorService.shutdown(); |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|