- Timestamp:
- 11/18/11 18:34:55 (13 years ago)
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
trunk/sources/HeuristicLab.Clients.Hive/3.3/RefreshableJob.cs
r6994 r7020 194 194 this.Job = new Job(); 195 195 this.log = new ThreadSafeLog(); 196 this.jobDownloader = new ConcurrentTaskDownloader<ItemTask>( 2, 2);196 this.jobDownloader = new ConcurrentTaskDownloader<ItemTask>(Settings.Default.MaxParallelDownloads, Settings.Default.MaxParallelDownloads); 197 197 this.jobDownloader.ExceptionOccured += new EventHandler<EventArgs<Exception>>(jobDownloader_ExceptionOccured); 198 198 this.HiveTasks = new ItemCollection<HiveTask>(); … … 202 202 this.Job = hiveExperiment; 203 203 this.log = new ThreadSafeLog(); 204 this.jobDownloader = new ConcurrentTaskDownloader<ItemTask>( 2, 2);204 this.jobDownloader = new ConcurrentTaskDownloader<ItemTask>(Settings.Default.MaxParallelDownloads, Settings.Default.MaxParallelDownloads); 205 205 this.jobDownloader.ExceptionOccured += new EventHandler<EventArgs<Exception>>(jobDownloader_ExceptionOccured); 206 206 this.HiveTasks = new ItemCollection<HiveTask>(); … … 212 212 this.log = cloner.Clone(original.log); 213 213 this.RefreshAutomatically = false; // do not start results polling automatically 214 this.jobDownloader = new ConcurrentTaskDownloader<ItemTask>( 2, 2);214 this.jobDownloader = new ConcurrentTaskDownloader<ItemTask>(Settings.Default.MaxParallelDownloads, Settings.Default.MaxParallelDownloads); 215 215 this.jobDownloader.ExceptionOccured += new EventHandler<EventArgs<Exception>>(jobDownloader_ExceptionOccured); 216 216 this.HiveTasks = cloner.Clone(original.HiveTasks); … … 230 230 public void StartResultPolling() { 231 231 if (jobResultPoller == null) { 232 jobResultPoller = new JobResultPoller(job.Id, /*ApplicationConstants.ResultPollingInterval*/new TimeSpan(0, 0, 5)); //TODO: find a better place for ApplicationConstants232 jobResultPoller = new JobResultPoller(job.Id, Settings.Default.ResultPollingInterval); 233 233 RegisterResultPollingEvents(); 234 234 jobResultPoller.AutoResumeOnException = true;
Note: See TracChangeset
for help on using the changeset viewer.