Фоновые задания: быстро получить большие данные в 1С

Процедура ПроизвестиДлительноеВычисление(ПараметрыПроцедуры) Экспорт

    Попытка
        СоединениеAdoDb = УстановитьСоединение(ПараметрыПроцедуры.DataSource, ПараметрыПроцедуры.ЭтоЭмуляцияРаботы);
        КомандаAdodb = ВернутьКомандаАДОДБ();
        КомандаAdodb.CommandText = ПараметрыПроцедуры.ТекстЗапроса;

        НачатьТранзакцию();

        Если НЕ ПараметрыПроцедуры.ЭтоЭмуляцияРаботы Тогда
            КомандаAdodb.ActiveConnection = СоединениеAdoDb;
            //упакуем объект ТаблицаЗначений, Для больших таблиц - хороший выигрыш в объеме.
            УпакованнаяТЗ = Новый ХранилищеЗначения(ВыгрузитьЗапрос_ТаблЗнач_GetRows(КомандаAdodb.Execute()), Новый СжатиеДанных(9));
        Иначе
            УпакованнаяТЗ = Новый ХранилищеЗначения(ЗаполнитьТЗМусором(), Новый СжатиеДанных(9));
        КонецЕсли;

        ПараметрыПроцедуры.Вставить("Запрос", УпакованнаяТЗ);

        ЗаписьРС = РегистрыСведений.ВременныеИдентификаторыЗапросов.СоздатьМенеджерЗаписи();
        ЗаписьРС.Идентификатор = ПараметрыПроцедуры.Идентификатор;
        ЗаписьРС.Прочитать();
        ЗаполнитьЗначенияСвойств(ЗаписьРС, ПараметрыПроцедуры);
        ЗаписьРС.Записать(Истина);

        ЗафиксироватьТранзакцию();

    Исключение
        ОтменитьТранзакцию();
        ТекстОшибки = "Фоновый запрос не удался,текст:"+ПараметрыПроцедуры.ТекстЗапроса+"
                    |Ошибка:"+ОписаниеОшибки();
        ВызватьИсключение ТекстОшибки;
    КонецПопытки;

КонецПроцедуры

Функция ВыполнитьЗадачиПараллельно() Экспорт

	Перем л_ОбщаяТЗ;

	Отказ = Ложь;
	ПарамФоновых = ПараметрыФоновыхПотоков();
	тз_фоновых = ТЗ_Фоновых();

	Начало_Транспорта();

	КомандаADODB.CommandText = "select DISTINCT "+ИмяКлючевогоПоля+" FROM "+ИмяТаблицы;

	Если ЭтоЭмуляцияРаботы Тогда
		л_МассивЗнач = ЗаполнитьМассивМусором();
	Иначе
		л_МассивЗнач = ИмпортПотоками.ВыгрузитьЗапрос_ТаблЗнач_GetRows(КомандаADODB.Execute()).ВыгрузитьКолонку(ИмяКлючевогоПоля);
	КонецЕсли;

	СтруктураМассивов = РазбитьМассивНаСтруктуруМассивов(л_МассивЗнач, ПарамФоновых.МаксЗначВЗапросе-1);

	Если ЭтоЭмуляцияРаботы Тогда
		ПарамФоновых.ВключеныПотокиФоновых = Истина;
	Иначе
		ПарамФоновых.ВключеныПотокиФоновых = СтруктураМассивов.Количество()-1 >= ПарамФоновых.ПорогДляПорожденияФоновых И НЕ ИнформационнаяБазаФайловая();
	КонецЕсли;

	инд = 0;
	Для каждого КлючЗначение Из СтруктураМассивов Цикл
		инд = инд + 1;
		ТекстЗапроса = ТекстЗапросаДляАДС(КлючЗначение.Значение, ИмяКлючевогоПоля);

		Если ПарамФоновых.ВключеныПотокиФоновых Тогда

			Если инд%ПарамФоновых.МаксПотоковДержитСистема = 0 Тогда
				ОтветыФоновых = СобратьОтветыФоновыхЗаданий(тз_Фоновых);
				Если НЕ ОтветыФоновых.Успешно Тогда
					Отказ = Истина;
					Прервать;
				КонецЕсли;

				Если НЕ ЗначениеЗаполнено(л_ОбщаяТЗ) Тогда
					л_ОбщаяТЗ = ОтветыФоновых.ОбщаяТЗ;
				Иначе
					ДобавитьСтрокиВТаблицу(л_ОбщаяТЗ, ОтветыФоновых.ОбщаяТЗ);
				КонецЕсли;
			КонецЕсли;

			ЗапуститьДлительныеВычисленияНаСервере(ПараметрыПроцедуры(ТекстЗапроса), тз_Фоновых);

		Иначе
			КомандаADODB.CommandText = ТекстЗапроса;
			Если НЕ ЭтоЭмуляцияРаботы Тогда
				л_ВТтз = ИмпортПотоками.ВыгрузитьЗапрос_ТаблЗнач_GetRows(КомандаADODB.Execute());
			КонецЕсли;
			Если НЕ ЗначениеЗаполнено(л_ОбщаяТЗ) Тогда
				л_ОбщаяТЗ = л_ВТтз.Скопировать();
			Иначе
				ДобавитьСтрокиВТаблицу(л_ОбщаяТЗ, л_ВТтз);
			КонецЕсли;
		КонецЕсли;
	КонецЦикла;
	
	Если ПарамФоновых.ВключеныПотокиФоновых И НЕ Отказ Тогда
		ОтветыФоновых = СобратьОтветыФоновыхЗаданий(тз_Фоновых);
		Если ОтветыФоновых.Успешно Тогда
			Если НЕ ЗначениеЗаполнено(л_ОбщаяТЗ) Тогда
				л_ОбщаяТЗ = ОтветыФоновых.ОбщаяТЗ;
			Иначе
				ДобавитьСтрокиВТаблицу(л_ОбщаяТЗ, ОтветыФоновых.ОбщаяТЗ);
			КонецЕсли;
		КонецЕсли;
	КонецЕсли;

	Возврат л_ОбщаяТЗ;

КонецФункции


Функция СобратьОтветыФоновыхЗаданий(Знач тз_Фоновых)

	л_ОбщаяТЗ = Неопределено;
	СтруктураОтвета = Новый Структура("Успешно,ОбщаяТЗ",Ложь,Неопределено);
	массив_Фоновых = Новый Массив;
	УспешноВернулось = 0;

	Для каждого СтрокаФЗ Из тз_Фоновых Цикл
		Если СтрокаФЗ.Отработано Тогда
			Продолжить;
		Иначе
			массив_Фоновых.Добавить(СтрокаФЗ.ФЗ);
		КонецЕсли;
	КонецЦикла;

	Если массив_Фоновых.Количество() = 0 Тогда
		Возврат СтруктураОтвета;
	КонецЕсли;

	Попытка
		ФоновыеЗадания.ОжидатьЗавершения(массив_Фоновых);

		НачатьТранзакцию();

		Для каждого СтрокаФЗ Из тз_Фоновых Цикл

			Если СтрокаФЗ.Отработано Тогда
				Продолжить;
			Иначе
				ЗаписьРС = РегистрыСведений.ВременныеИдентификаторыЗапросов.СоздатьМенеджерЗаписи();
				ЗаписьРС.Идентификатор = СтрокаФЗ.Идентификатор;
				ЗаписьРС.Прочитать();
				Если ЗаписьРС.Выбран() Тогда
					СтрокаФЗ.Отработано = Истина;
					Если УспешноВернулось = 0 Тогда
						л_ОбщаяТЗ = ЗаписьРС.Запрос.Получить();
					Иначе
						ДобавитьСтрокиВТаблицу(л_ОбщаяТЗ, ЗаписьРС.Запрос.Получить());
					КонецЕсли;
					УспешноВернулось = УспешноВернулось+1;
					ЗаписьРС.Удалить();
				КонецЕсли;
			КонецЕсли;
		КонецЦикла;

		Если УспешноВернулось = массив_Фоновых.Количество() Тогда
			СтруктураОтвета.Успешно = Истина;
			СтруктураОтвета.ОбщаяТЗ = л_ОбщаяТЗ;
			ЗафиксироватьТранзакцию();
		КонецЕсли;

	Исключение
		ОтменитьТранзакцию();
		ТекстОшибки = ОписаниеОшибки();
	КонецПопытки;

	Возврат СтруктураОтвета;

КонецФункции

Процедура ЗапуститьДлительныеВычисленияНаСервере(Знач ПарамПроцедуры, тз_Фоновых)

	СтрокаТЗ = тз_Фоновых.Добавить();
	ЗаполнитьЗначенияСвойств(СтрокаТЗ, ПарамПроцедуры);
	СтрокаТЗ.Отработано = Ложь;

	ПараметрыЗадания = Новый Массив;
	ПараметрыЗадания.Добавить(ПарамПроцедуры);

	СтрокаТЗ.ФЗ = ФоновыеЗадания.Выполнить(ПарамПроцедуры.ИмяМетодаФЗ,ПараметрыЗадания,ПарамПроцедуры.Идентификатор);

КонецПроцедуры