diff options
author | slewis | 2010-09-03 04:08:21 +0000 |
---|---|---|
committer | slewis | 2010-09-03 04:08:21 +0000 |
commit | 0e9a97e6e47e0f2456b323beeeda6372c9027afd (patch) | |
tree | ea407ee286cb5320042d58b1ddaa56ea4213116f /providers/bundles | |
parent | 25ed94b75ff7ed2941d0ecf778d4e2e8874ddf29 (diff) | |
download | org.eclipse.ecf-0e9a97e6e47e0f2456b323beeeda6372c9027afd.tar.gz org.eclipse.ecf-0e9a97e6e47e0f2456b323beeeda6372c9027afd.tar.xz org.eclipse.ecf-0e9a97e6e47e0f2456b323beeeda6372c9027afd.zip |
Extension to use concurrent API for remote service execution
Diffstat (limited to 'providers/bundles')
-rw-r--r-- | providers/bundles/org.eclipse.ecf.provider.remoteservice/src/org/eclipse/ecf/provider/remoteservice/generic/RegistrySharedObject.java | 14 |
1 files changed, 11 insertions, 3 deletions
diff --git a/providers/bundles/org.eclipse.ecf.provider.remoteservice/src/org/eclipse/ecf/provider/remoteservice/generic/RegistrySharedObject.java b/providers/bundles/org.eclipse.ecf.provider.remoteservice/src/org/eclipse/ecf/provider/remoteservice/generic/RegistrySharedObject.java index 686cb43d7..0f93e2049 100644 --- a/providers/bundles/org.eclipse.ecf.provider.remoteservice/src/org/eclipse/ecf/provider/remoteservice/generic/RegistrySharedObject.java +++ b/providers/bundles/org.eclipse.ecf.provider.remoteservice/src/org/eclipse/ecf/provider/remoteservice/generic/RegistrySharedObject.java @@ -1100,14 +1100,22 @@ public class RegistrySharedObject extends BaseSharedObject implements IRemoteSer return requestExecutor; } - private IExecutor createRequestExecutor(Request request) { + private IExecutor createRequestExecutor(final Request request) { IExecutor executor = null; if (DEFAULT_EXECUTOR_TYPE.equals("jobs")) { //$NON-NLS-1$ - executor = new JobsExecutor("Remote Request Handler"); //$NON-NLS-1$ + executor = new JobsExecutor("Remote Request Handler") { //$NON-NLS-1$ + protected String createJobName(String executorName, int jobCounter, IProgressRunnable runnable) { + return executorName + " - " + request.getCall().getMethod() + ":" + request.getRequestId(); //$NON-NLS-1$ //$NON-NLS-2$ + } + }; } else if (DEFAULT_EXECUTOR_TYPE.equals("immediate")) { //$NON-NLS-1$ executor = new ImmediateExecutor(); } else { - executor = new ThreadsExecutor(); + executor = new ThreadsExecutor() { + protected String createThreadName(IProgressRunnable runnable) { + return "Remote Request Handler - " + request.getCall().getMethod() + ":" + request.getRequestId(); //$NON-NLS-1$ //$NON-NLS-2$ + } + }; } return executor; } |