Remove SynchronizableObjectsRegistry

src/vs/platform/test/common/nullThreadService.ts

@@ -40,10 +40,6 @@ export class NullThreadService extends abstractThreadService.AbstractThreadServi
 		return target.apply(obj, params);
 	}
 
-	ensureWorkers(): void {
-		// Nothing to do
-	}
-
 	addStatusListener(listener: IThreadServiceStatusListener): void {
 		// Nothing to do
 	}

src/vs/platform/thread/common/mainThreadService.ts

@@ -12,7 +12,6 @@ import Platform = require('vs/base/common/platform');
 import errors = require('vs/base/common/errors');
 import Timer = require('vs/base/common/timer');
 import remote = require('vs/base/common/remote');
-import {readThreadSynchronizableObjects} from 'vs/platform/thread/common/threadService';
 import {SyncDescriptor0} from 'vs/platform/instantiation/common/descriptors';
 import {IThreadService, IThreadServiceStatusListener, IThreadSynchronizableObject, ThreadAffinity, IThreadServiceStatus} from 'vs/platform/thread/common/thread';
 import {IWorkspaceContextService} from 'vs/platform/workspace/common/workspace';
@@ -65,9 +64,6 @@ export class MainThreadService extends abstractThreadService.AbstractThreadServi
 			// Not cancelable
 		});
 
-		// Register all statically instantiated synchronizable objects
-		readThreadSynchronizableObjects().forEach((obj) => this.registerInstance(obj));
-
 		// If nobody asks for workers to be created in 5s, the workers are created automatically
 		TPromise.timeout(MainThreadService.MAXIMUM_WORKER_CREATION_DELAY).then(() => this.ensureWorkers());
 	}

src/vs/platform/thread/common/pluginHostThreadService.ts

@@ -9,7 +9,6 @@ import remote = require('vs/base/common/remote');
 import descriptors = require('vs/platform/instantiation/common/descriptors');
 
 import abstractThreadService = require('./abstractThreadService');
-import {readThreadSynchronizableObjects} from 'vs/platform/thread/common/threadService';
 import {IThreadService, IThreadSynchronizableObject, ThreadAffinity, IThreadServiceStatusListener} from 'vs/platform/thread/common/thread';
 
 export class PluginHostThreadService extends abstractThreadService.AbstractThreadService implements IThreadService {
@@ -20,9 +19,6 @@ export class PluginHostThreadService extends abstractThreadService.AbstractThrea
 		super(false);
 		this._remoteCom = remoteCom;
 		this._remoteCom.setManyHandler(this);
-
-		// Register all statically instantiated synchronizable objects
-		readThreadSynchronizableObjects().forEach((obj) => this.registerInstance(obj));
 	}
 
 	MainThread(obj: IThreadSynchronizableObject<any>, methodName: string, target: Function, params: any[]): TPromise<any> {
@@ -41,10 +37,6 @@ export class PluginHostThreadService extends abstractThreadService.AbstractThrea
 		return target.apply(obj, params);
 	}
 
-	ensureWorkers(): void {
-		// Nothing to do
-	}
-
 	addStatusListener(listener: IThreadServiceStatusListener): void {
 		// Nothing to do
 	}

src/vs/platform/thread/common/thread.ts

@@ -23,7 +23,6 @@ export interface IThreadService {
 	// --- BEGIN deprecated methods
 	isInMainThread: boolean;
 
-	ensureWorkers(): void;
 	addStatusListener(listener: IThreadServiceStatusListener): void;
 	removeStatusListener(listener: IThreadServiceStatusListener): void;
 

src/vs/platform/thread/common/threadService.ts

@@ -87,35 +87,3 @@ export function EverywhereAttr(type: Function, target: Function): void {
 		return findThreadService(this).Everywhere(this, methodName, target, param);
 	};
 }
-
-class SynchronizableObjectsRegistry {
-	private _list: thread.IThreadSynchronizableObject<any>[] = [];
-
-	constructor() {
-		this._list = [];
-	}
-
-	public register(obj: thread.IThreadSynchronizableObject<any>): void {
-		this._list.push(obj);
-	}
-
-	public read(): thread.IThreadSynchronizableObject<any>[] {
-		return this._list;
-	}
-}
-
-export const Extensions = {
-	SynchronizableObjects: 'SynchronizableObjects'
-};
-
-Platform.Registry.add(Extensions.SynchronizableObjects, new SynchronizableObjectsRegistry());
-
-export function registerThreadSynchronizableObject(obj: thread.IThreadSynchronizableObject<any>): void {
-	let registry = <SynchronizableObjectsRegistry>Platform.Registry.as(Extensions.SynchronizableObjects);
-	registry.register(obj);
-}
-
-export function readThreadSynchronizableObjects(): thread.IThreadSynchronizableObject<any>[] {
-	let registry = <SynchronizableObjectsRegistry>Platform.Registry.as(Extensions.SynchronizableObjects);
-	return registry.read();
-}
\ No newline at end of file

src/vs/platform/thread/common/workerThreadService.ts

@@ -5,7 +5,6 @@
 'use strict';
 
 import {TPromise} from 'vs/base/common/winjs.base';
-import {readThreadSynchronizableObjects} from './threadService';
 import abstractThreadService = require('vs/platform/thread/common/abstractThreadService');
 import remote = require('vs/base/common/remote');
 import {SyncDescriptor0} from 'vs/platform/instantiation/common/descriptors';
@@ -28,9 +27,6 @@ export class WorkerThreadService extends abstractThreadService.AbstractThreadSer
 		this._remoteCom.setManyHandler(this);
 
 		this._publisher = workerPublisher;
-
-		// Register all statically instantiated synchronizable objects
-		readThreadSynchronizableObjects().forEach((obj) => this.registerInstance(obj));
 	}
 
 	private _handleRequest(identifier: string, memberName: string, args: any[]): TPromise<any> {
@@ -96,10 +92,6 @@ export class WorkerThreadService extends abstractThreadService.AbstractThreadSer
 		return target.apply(obj, params);
 	}
 
-	ensureWorkers(): void {
-		// Nothing to do
-	}
-
 	addStatusListener(listener: IThreadServiceStatusListener): void {
 		// Nothing to do
 	}