Модераторы: Poseidon, Snowy, bems, MetalFan
  

Поиск:

Ответ в темуСоздание новой темы Создание опроса
> Загрузка файла в Stream через Thread, Помогите пожалуйста, срочно надо! 
:(
    Опции темы
ZeroDivide
  Дата 12.8.2005, 18:37 (ссылка)    |    (голосов: 0) Загрузка ... Загрузка ... Быстрая цитата Цитата


Unregistered











Я написал модуль, загружающий файл в TMemoryStream (надо для игрового движка).
Код

unit ZDLoader;

interface

uses
  SysUtils, Classes;

type
  TZDLoader = class(TThread)
  private
    FStream: TMemoryStream;
    FFileName: string;
  public
    property Stream: TMemoryStream read FStream write FStream;
    property FileName: string read FFileName write FFileName;
  published
    procedure Execute; override;
  end;

function LoadStream(AFileName: string): TMemoryStream;

implementation

procedure TZDLoader.Execute;
var
  Loader: TMemoryStream;
begin
  if not Assigned(FStream) then
    Exit;
  if not FileExists(FFileName) then
    Exit;
  Loader := TMemoryStream.Create;
  Loader.LoadFromFile(FFileName);
  FStream.CopyFrom(Loader, Loader.Size);
  FStream.Position := 0;
  Loader.Free;
  FreeOnTerminate := true;
end;

function LoadStream(AFileName: string): TMemoryStream;
var
  Thread: TZDLoader;
begin
  Thread := TZDLoader.Create(false);
  Result := TMemoryStream.Create;
  Thread.Stream := Result;
  Thread.FileName := AFileName;
  Thread.Execute;
  Thread.Free;
end;

end.


Файл загружаю функцией LoadStream.
На маленьких файлах работает отлично, но с большими (вроде более 800 килобайт) возникает исключение: "Stream read error. Out of memory while expanding memory stream".
Перепробовал кучу способов (Read/Write, через файлы, через хендлы), ничего не изменилось. smile
Как исправить?
Заранее спасибо за ответы.
  Вверх
_hunter
Дата 12.8.2005, 18:50 (ссылка) | (нет голосов) Загрузка ... Загрузка ... Быстрая цитата Цитата


Эксперт
****


Профиль
Группа: Участник Клуба
Сообщений: 8564
Регистрация: 24.6.2003
Где: Europe::Ukraine:: Kiev

Репутация: 15
Всего: 98



перед FStream.CopyFrom нужно позицию Loader-а в 0 поставить...


--------------------
Tempora mutantur, et nos mutamur in illis...
PM ICQ   Вверх
Guest
Дата 12.8.2005, 19:29 (ссылка)    |    (голосов: 0) Загрузка ... Загрузка ... Быстрая цитата Цитата


Unregistered











Это я просто криво код скопировал smile
Изменений нет. Всё тот же "Stream read error. Out of memory while expanding memory stream".
Памяти у меня 1024 МБ + файл подкачки.
  Вверх
p0s0l
Дата 12.8.2005, 21:30 (ссылка) | (нет голосов) Загрузка ... Загрузка ... Быстрая цитата Цитата


Г-н Посол
****


Профиль
Группа: Экс. модератор
Сообщений: 3668
Регистрация: 13.7.2003
Где: 58°38' с.ш. 4 9°41' в.д.

Репутация: 58
Всего: 112



По всей видимости, памяти у тебя маловато...
Может забываешь где-нибудь освобождать память ?...
У себя сейчас проверил - ошибка вылазит, если кончается вся виртуальная память (у меня 512RAM + 1GB Swap)...
Также даже если у тебя виртуальная память больше 2ГБ - проку мало, т.к. в NT-системах для пользовательских процессов доступна только половина адресного пространства, т.е. 2 Гб... (про Win9x - не знаю...)


--------------------
С уважением, г-н Посол.
PM   Вверх
Guest
Дата 13.8.2005, 09:39 (ссылка)    |    (голосов: 0) Загрузка ... Загрузка ... Быстрая цитата Цитата


Unregistered











У меня Windows XP.
Быть того не может, чтобы памяти не хватило...
А другого способа нет?
  Вверх
Illusion Dolphin
Дата 13.8.2005, 10:01 (ссылка) | (нет голосов) Загрузка ... Загрузка ... Быстрая цитата Цитата


Эксперт
***


Профиль
Группа: Участник Клуба
Сообщений: 1198
Регистрация: 3.5.2003

Репутация: 36
Всего: 63



p0s0l, к чему размер памяти? Ты ж посмотри, что там в коде написано smile !

Код

unit ZDLoader;

interface

uses
  SysUtils, Classes;

type
  TZDLoader = class(TThread)
...
  end;

function LoadStream(AFileName: string): TMemoryStream;

implementation

...

function LoadStream(AFileName: string): TMemoryStream;
var
  Thread: TZDLoader;
begin
  Thread := TZDLoader.Create(false); //парамерт функции Create определяет, будет ли поток созданн приостановленным - у тебя нет, значит поток в этом месте уже запускается
  Result := TMemoryStream.Create; //тут идёт время на создание потока
  Thread.Stream := Result; // поток уже запущен, функция execute уже выполняется, так что присвоение Stream может немного запоздать ;)
  Thread.FileName := AFileName; //аналогично
  Thread.Execute; //таааак низя! эта функция уже выполняется и в какой-то стадии выполнения, так что что тут у тебя теперь получается знаит один бог
  Thread.Free; //и вот поток проработал ровно столько сколько выполнялось присвоение данных и создание нового потока, неудивительно что больше 800 кило он не успел прочитать  :D 
end;

end.

Для начала прочитай про многопоточность, может вопрос у тебя решится сам собой. Но если вопрос очень нужен, то тебе придётся сделать всё хотя бы по такому сценарию:
1) Создаём поток Thread := TZDLoader.Create(true);
2) присваиваем свойства
3) запускаем поток Thread.Resume; (Thread.free вызывать не нужно!)
4) из потока при завершении операции чтения вызываем функцию основного приложения для того чтобы передать указатель на поток с прочитанными данными (используй Synchronize)


--------------------
В мире всего две бесконечности: вселенная и человеческая глупость... На счёт вселенной я не уверен.
Шифрование и организация фотографий - Photo Database 4.5
PM MAIL WWW ICQ   Вверх
p0s0l
Дата 13.8.2005, 11:16 (ссылка) | (нет голосов) Загрузка ... Загрузка ... Быстрая цитата Цитата


Г-н Посол
****


Профиль
Группа: Экс. модератор
Сообщений: 3668
Регистрация: 13.7.2003
Где: 58°38' с.ш. 4 9°41' в.д.

Репутация: 58
Всего: 112



Мдя... Тестил я на простом TMemoryStream.SetSize... На LoadStream не посмотрел smile, не думал, что можно догадаться такое написать, это всё равно что в одном слове допустить 10 ошибок smile...


--------------------
С уважением, г-н Посол.
PM   Вверх
Guest
Дата 13.8.2005, 19:10 (ссылка)    |    (голосов: 0) Загрузка ... Загрузка ... Быстрая цитата Цитата


Unregistered











А по-моему ничего смешного smile
Я впервые работаю с TThread`ами.
А вот про Synchronize я почти ничего не понимаю, я знаю, что его используют для синхронизации данных между двумя потоками.
Можете обеспечить ламера smile в потоках нормальным, рабочим кодом?
smile
  Вверх
p0s0l
Дата 13.8.2005, 19:36 (ссылка) | (нет голосов) Загрузка ... Загрузка ... Быстрая цитата Цитата


Г-н Посол
****


Профиль
Группа: Экс. модератор
Сообщений: 3668
Регистрация: 13.7.2003
Где: 58°38' с.ш. 4 9°41' в.д.

Репутация: 58
Всего: 112



ZeroDivide, почитай о потоках в в этой статье, всё расжевано.
http://forum.vingrad.ru/index.php?showtopic=60076&view=all
Потратишь время на чтение, но сэкономишь его на отлове багов...

PS: Можно уже и зарегистрироваться smile. Движок для игры - дело долгое, помощь еще не раз потребуется smile



--------------------
С уважением, г-н Посол.
PM   Вверх
ZeroDivide
Дата 13.8.2005, 20:20 (ссылка)    |    (голосов: 0) Загрузка ... Загрузка ... Быстрая цитата Цитата


Unregistered











p0s0l, я уже скачал, буду читать. Ты не думай, что я ламер smile я просто впервые с Thread`ами встречаюсь.
И всё таки ты можешь переписать мой модуль? Ведь про потоки читать-то много... smile
  Вверх
p0s0l
Дата 13.8.2005, 21:21 (ссылка) | (нет голосов) Загрузка ... Загрузка ... Быстрая цитата Цитата


Г-н Посол
****


Профиль
Группа: Экс. модератор
Сообщений: 3668
Регистрация: 13.7.2003
Где: 58°38' с.ш. 4 9°41' в.д.

Репутация: 58
Всего: 112



ZeroDivide, сделай так как написал Illusion Dolphin:
Код

unit ZDLoader;    

interface    

uses    
  SysUtils, Classes;    

type    
  TZDLoader = class(TThread)    
  private    
    FStream: TMemoryStream;    
    FFileName: string;
  protected
    procedure Signal;    
  public    
    property Stream: TMemoryStream read FStream write FStream;    
    property FileName: string read FFileName write FFileName;    
  published    
    procedure Execute; override;    
  end;    

function LoadStream(AFileName: string): TMemoryStream;    

implementation    

procedure TZDLoader.Execute;    
begin    
  if not Assigned(Stream) then    
    Exit;    
  if not FileExists(FileName) then    
    Exit;    
  Stream.LoadFromFile(FileName);    
  Stream.Position := 0;    
  Synchronize(Signal);
  FreeOnTerminate := True;
end;    

procedure TZDLoader.Signal;
begin
// как-нибудь оповещай, что мол загрузка закончилась, теперь можно юзать Stream, например так:
  MainForm.LoadingComplete (Stream, FileName);
end;

function LoadStream(const AFileName: string): TMemoryStream;    
var    
  Thread: TZDLoader;    
begin    
  Thread := TZDLoader.Create(True);
  Result := TMemoryStream.Create;
  Thread.Stream := Result;
  Thread.FileName := AFileName;
  Thread.Resume;
end;    

end.



--------------------
С уважением, г-н Посол.
PM   Вверх
Illusion Dolphin
Дата 13.8.2005, 21:40 (ссылка) | (нет голосов) Загрузка ... Загрузка ... Быстрая цитата Цитата


Эксперт
***


Профиль
Группа: Участник Клуба
Сообщений: 1198
Регистрация: 3.5.2003

Репутация: 36
Всего: 63



Я бы сделал так:

Код

unit ZDLoader;

interface

uses
  SysUtils, Classes;

type
  TProcEndFileThreadLoadToStream = procedure(Sender : TObject; ID : String; Stream : TMemoryStream) of object;

type
  TZDLoader = class(TThread)
  private
    FStream: TMemoryStream;
    FFileName: string;
    FID : String;
    FProc : TProcEndFileThreadLoadToStream;
    procedure FileLoaded;
  public
    constructor Create(CreateSuspennded: Boolean; ID: String; FileName : String; Proc : TProcEndFileThreadLoadToStream);
    property Stream: TMemoryStream read FStream write FStream;
  published
    procedure Execute; override;
  end;

implementation

constructor TZDLoader.Create(CreateSuspennded: Boolean; ID: String; FileName: String; Proc : TProcEndFileThreadLoadToStream);
begin
 inherited Create(true);
 FFileName:=FileName;
 FID:=ID;
 FProc:=Proc;
 if not CreateSuspennded then Resume;
end;

procedure TZDLoader.Execute;
var
  Loader: TMemoryStream;

  procedure DoExit;
  begin
   Synchronize(FileLoaded);
  end;

begin
 FreeOnTerminate := true;
 if not FileExists(FFileName) then
 begin
  FStream:=nil;
  DoExit;
  Exit;
 end;
 FStream := TMemoryStream.Create;
 FStream.LoadFromFile(FFileName);
 DoExit;
end;

procedure TZDLoader.FileLoaded;
begin
 FProc(Self,FID,FStream);
end;

end.


Код

unit Unit1;

interface

uses
  Windows, Messages, SysUtils, Variants, Classes, Graphics, Controls, Forms,
  Dialogs, ZDLoader, StdCtrls;

type
  TForm1 = class(TForm)
    Button1: TButton;
    procedure Button1Click(Sender: TObject);
    procedure FileLoaded(Sender : TObject; ID : String; Stream : TMemoryStream);
  private
    { Private declarations }
  public
    { Public declarations }
  end;

var
  Form1: TForm1;

implementation

{$R *.dfm}

procedure TForm1.Button1Click(Sender: TObject);
begin
// типа зачем нужен ID? я его обычно генерирую как GUID и
//потом можно использовать одну процедуру для
//всех файлов и в ней разбираться в какой стриме какой файл
 TZDLoader.Create(false,'1','C:\test.dat',FileLoaded);
end;

procedure TForm1.FileLoaded(Sender: TObject; ID: String;
  Stream: TMemoryStream);
begin
 if ID='1' then
 begin
  if Stream=nil then showmessage('Афыпка!') else
  begin
   ShowMessage('Размер загруженного файла - '+inttostr(round(Stream.Size/(1024*1024)))+ ' Mb');
   Stream.Free;
  end;
 end;
end;

end.



P.S. запоздал ))) уже запостили почти тот же вариант

Это сообщение отредактировал(а) Illusion Dolphin - 13.8.2005, 21:42


--------------------
В мире всего две бесконечности: вселенная и человеческая глупость... На счёт вселенной я не уверен.
Шифрование и организация фотографий - Photo Database 4.5
PM MAIL WWW ICQ   Вверх
ZeroDivide
Дата 14.8.2005, 08:12 (ссылка) | (нет голосов) Загрузка ... Загрузка ... Быстрая цитата Цитата


Новичок



Профиль
Группа: Участник
Сообщений: 4
Регистрация: 14.8.2005

Репутация: нет
Всего: 1



Я зарегистрировался smile smile
Спасибо все отвечавшим!
PM MAIL   Вверх
  
Ответ в темуСоздание новой темы Создание опроса
Правила форума "Delphi: Общие вопросы"
SnowyMetalFan
bemsPoseidon
Rrader

Запрещается!

1. Публиковать ссылки на вскрытые компоненты

2. Обсуждать взлом компонентов и делиться вскрытыми компонентами

  • Литературу по Дельфи обсуждаем здесь
  • Действия модераторов можно обсудить здесь
  • С просьбами о написании курсовой, реферата и т.п. обращаться сюда
  • Вопросы по реализации алгоритмов рассматриваются здесь
  • 90% ответов на свои вопросы можно найти в DRKB (Delphi Russian Knowledge Base) - крупнейшем в рунете сборнике материалов по Дельфи


Если Вам понравилась атмосфера форума, заходите к нам чаще! С уважением, Snowy, MetalFan, bems, Poseidon, Rrader.

 
1 Пользователей читают эту тему (1 Гостей и 0 Скрытых Пользователей)
0 Пользователей:
« Предыдущая тема | Delphi: Общие вопросы | Следующая тема »


 




[ Время генерации скрипта: 0.0784 ]   [ Использовано запросов: 21 ]   [ GZIP включён ]


Реклама на сайте     Информационное спонсорство

 
По вопросам размещения рекламы пишите на vladimir(sobaka)vingrad.ru
Отказ от ответственности     Powered by Invision Power Board(R) 1.3 © 2003  IPS, Inc.