diff options
author | slewis | 2010-09-03 04:09:34 +0000 |
---|---|---|
committer | slewis | 2010-09-03 04:09:34 +0000 |
commit | 9b7e0cebbcf7394a42c0ee23026b663536b8b35f (patch) | |
tree | 0bdc38723c0e6f2d32e2912b2720990d7912c28e | |
parent | 871242b70e3202e0f57db8b119baa910a2e66705 (diff) | |
download | org.eclipse.ecf-R-Release_3_3-sdk_feature-16-2010_09_03.tar.gz org.eclipse.ecf-R-Release_3_3-sdk_feature-16-2010_09_03.tar.xz org.eclipse.ecf-R-Release_3_3-sdk_feature-16-2010_09_03.zip |
Extension to use concurrent API for remote service executionR-Release_3_3-sdk_feature-16-2010_09_03
-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; } |