第一次寫多線程，大致地寫個載入模塊，請大家指正

funcman

1. // Loader.h
   
2. #ifndef LOADER_H
   
3. #define LOADER_H
   
4. 
   
5. extern "C" {
   
6. 
   
7. typedef struct LoadRequest_ LoadRequest;
   
8. 
   
9. LoadRequest*SendRequest(char* filename);
   
10. void        ReleaseRequest(LoadRequest* request);
    
11. void*       GetData(LoadRequest* request);
    
12. bool        IsReady(LoadRequest* request);
    
13. bool        IsError(LoadRequest* request);
    
14. 
    
15. }//extern "C"
    
16. 
    
17. #endif//LOADER_H
    

復制代碼

1. // Loader.cpp
   
2. #include "Loader.h"
   
3. #include <stdio.h>
   
4. #include <stdlib.h>
   
5. #include <string.h>
   
6. #include <assert.h>
   
7. #include <pthread.h>
   
8. 
   
9. extern "C" {
   
10. 
    
11. typedef enum RequestState_ {
    
12.     LOADING,
    
13.     READY,
    
14.     ERROR,
    
15. } RequestState;
    
16. 
    
17. typedef struct Request_ {
    
18.     RequestState    stat;
    
19.     char            filename[512];
    
20.     void*           data;
    
21. } Request;
    
22. 
    
23. void* load_func_(void* arg) {
    
24.     assert(arg);
    
25.     Request* req = (Request*)arg;
    
26.     FILE* fp = fopen(req->filename, "r");
    
27.     if( !fp ) req->stat = ERROR;
    
28.     else {
    
29.         fseek(fp, 0, SEEK_END);
    
30.         int len = ftell(fp);
    
31.         req->data = malloc(len);
    
32.         if( !(req->data) ) req->stat = ERROR;
    
33.         else {
    
34.             fseek(fp, 0, SEEK_SET);
    
35.             fread(req->data, len, 1, fp);
    
36.             req->stat = READY;
    
37.         }
    
38.         fclose(fp);
    
39.     }
    
40.     return 0;
    
41. }
    
42. 
    
43. LoadRequest* SendRequest(char* filename) {
    
44.     pthread_t t;
    
45.     Request* req = (Request*)malloc(sizeof(Request));
    
46.     if(!req) return 0;
    
47.     req->stat = LOADING;
    
48.     strcpy(req->filename, filename);
    
49.     pthread_create(&t, 0, load_func_, req);
    
50.     return (LoadRequest*)req;
    
51. }
    
52. 
    
53. void ReleaseRequest(LoadRequest* request) {
    
54.     assert(request);
    
55.     Request* req = (Request*)request;
    
56.     assert(req->stat==READY);
    
57.     free(req->data);
    
58.     free(req);
    
59. }
    
60. 
    
61. void* GetData(LoadRequest* request) {
    
62.     assert(request);
    
63.     Request* req = (Request*)request;
    
64.     if( req->stat != READY ) return 0;
    
65.     return req->data;
    
66. }
    
67. 
    
68. bool IsReady(LoadRequest* request) {
    
69.     assert(request);
    
70.     Request* req = (Request*)request;
    
71.     return (req->stat==READY);
    
72. }
    
73. 
    
74. bool IsError(LoadRequest* request) {
    
75.     assert(request);
    
76.     Request* req = (Request*)request;
    
77.     return (req->stat==ERROR);
    
78. }
    
79. 
    
80. }//extern "C"
    

復制代碼

1. // Main.cpp
   
2. #include <stdio.h>
   
3. #include "Loader.h"
   
4. 
   
5. int main(void) {
   
6.     LoadRequest* req = SendRequest("test.txt");
   
7.     while( !IsReady(req) ) {
   
8.         if( IsError(req) ) {
   
9.             printf("Error!\n");
   
10.             break;
    
11.         }
    
12.         printf("Loading...\n");
    
13.     }
    
14.     if( IsReady(req) ) {
    
15.         printf("Ready!\nThe text is:%s\n", (char*)GetData(req));
    
16.     }
    
17.     return 0;
    
18. }
    

復制代碼

編譯自然是：
$ g++ Loader.cpp Main.cpp -o MLLoader

運行是正常的。

我就是想知道，我這么寫是不是包含了很多潛在的錯誤。
謝家指正！
：）

hellioncu

沒有調(diào)用ReleaseRequest釋放。
多線程讀文件并不能快多少吧

funcman

不求快,求不阻塞.

代碼本身問題還很多...

pengjianbokobe

如果文件很大，你這樣讀，會把整個文件讀到緩沖區(qū)，很好內(nèi)存

funcman

不管大文件