纖程和執行緒里面按程式呼叫函式有什么區別？-有解無憂

#include <Windows.h>

#include <strsafe.h>

#include <tchar.h>





#define PRIMARY_FIBER 0

#define WRITE_FIBER 1

#define READ_FIBER 2

#define FIBER_COUNT 3

#define COPY_LENGTH 512



VOID CALLBACK ReadFiber(LPVOID lpParam);

VOID CALLBACK WriteFiber(LPVOID lpParam);



typedef struct _tagFIBER_STRUCT

{

	DWORD dwFiberHandle;

	HANDLE hFile;

	LPVOID lpParam;

}FIBER_STRUCT, *LPFIBER_STRUCT;



char *g_lpBuffer = NULL;

LPVOID g_lpFiber[FIBER_COUNT] = {};

void GetApp(LPTSTR lpPath, int nBufLen)

{

	TCHAR szBuf[MAX_PATH] = _T("");

	GetModuleFileName(NULL, szBuf, MAX_PATH);



	int nLen = _tcslen(szBuf);

	for (int i = nLen; i > 0; i--)

	{

		if (szBuf[i] == '\\')

		{

			szBuf[i + 1] = _T('\0');

			break;

		}

	}



	nLen = _tcslen(szBuf) + 1;

	int nCopyLen = min(nLen, nBufLen);

	StringCchCopy(lpPath, nCopyLen, szBuf);

}



int _tmain(int argc, _TCHAR* argv[])

{

	g_lpBuffer = (char*)HeapAlloc(GetProcessHeap(), HEAP_ZERO_MEMORY, COPY_LENGTH);

	FIBER_STRUCT fs[FIBER_COUNT] = { 0 };



	TCHAR szDestPath[MAX_PATH] = _T("");

	TCHAR szSrcPath[MAX_PATH] = _T("");

	GetApp(szDestPath, MAX_PATH);

	GetApp(szSrcPath, MAX_PATH);

	StringCchCat(szSrcPath, MAX_PATH, _T("2.jpg"));

	StringCchCat(szDestPath, MAX_PATH, _T("2_Cpy.jpg"));



	HANDLE hSrcFile = CreateFile(szSrcPath, GENERIC_READ, 0, NULL, OPEN_EXISTING, 0, NULL);

	HANDLE hDestFile = CreateFile(szDestPath, GENERIC_WRITE, 0, NULL, CREATE_ALWAYS, 0, NULL);



	fs[PRIMARY_FIBER].hFile = INVALID_HANDLE_VALUE;

	fs[PRIMARY_FIBER].lpParam = NULL;

	fs[PRIMARY_FIBER].dwFiberHandle = 0x00001234;



	fs[WRITE_FIBER].hFile = hDestFile;

	fs[WRITE_FIBER].lpParam = NULL;

	fs[WRITE_FIBER].dwFiberHandle = 0x12345678;



	fs[READ_FIBER].hFile = hSrcFile;

	fs[READ_FIBER].dwFiberHandle = 0x78563412;

	fs[READ_FIBER].lpParam = NULL;



	g_lpFiber[PRIMARY_FIBER] = ConvertThreadToFiber(&fs[PRIMARY_FIBER]);

	g_lpFiber[READ_FIBER] = CreateFiber(0, (LPFIBER_START_ROUTINE)ReadFiber, &fs[READ_FIBER]);

	g_lpFiber[WRITE_FIBER] = CreateFiber(0, (LPFIBER_START_ROUTINE)WriteFiber, &fs[WRITE_FIBER]);



	//切換到讀纖程

	SwitchToFiber(g_lpFiber[READ_FIBER]);



	//洗掉纖程

	DeleteFiber(g_lpFiber[WRITE_FIBER]);

	DeleteFiber(g_lpFiber[READ_FIBER]);



	CloseHandle(fs[READ_FIBER].hFile);

	CloseHandle(fs[WRITE_FIBER].hFile);



	//變回執行緒

	ConvertFiberToThread();

	return 0;

}



VOID CALLBACK ReadFiber(LPVOID lpParam)

{

	//拷貝檔案

	while (TRUE)

	{

		LPFIBER_STRUCT pFS = (LPFIBER_STRUCT)lpParam;

		printf("切換到[%08x]纖程\n", pFS->dwFiberHandle);

		DWORD dwReadLen = 0;

		ZeroMemory(g_lpBuffer, COPY_LENGTH);

		ReadFile(pFS->hFile, g_lpBuffer, COPY_LENGTH, &dwReadLen, NULL);

		SwitchToFiber(g_lpFiber[WRITE_FIBER]);

		if (dwReadLen < COPY_LENGTH)

		{

			break;

		}

	}



	SwitchToFiber(g_lpFiber[PRIMARY_FIBER]);

}



VOID CALLBACK WriteFiber(LPVOID lpParam)

{

	while (TRUE)

	{

		LPFIBER_STRUCT pFS = (LPFIBER_STRUCT)lpParam;

		printf("切換到[%08x]纖程\n", pFS->dwFiberHandle);

		DWORD dwWriteLen = 0;

		WriteFile(pFS->hFile, g_lpBuffer, COPY_LENGTH, &dwWriteLen, NULL);

		SwitchToFiber(g_lpFiber[READ_FIBER]);

		if (dwWriteLen < COPY_LENGTH)

		{

			break;

		}

	}



	SwitchToFiber(g_lpFiber[PRIMARY_FIBER]);

}

以上是網上看文章介紹的纖程例子代碼：功能就是復制檔案。https://www.cnblogs.com/lanuage/p/7725683.html

想知道這樣 "讀纖程” 和 "寫纖程"相互呼叫和一個執行緒里面直接 while(1){ 判斷讀完沒有；讀函式; 寫函式;)有什么區別？

uj5u.com熱心網友回復：

沒有人理會。。。

uj5u.com熱心網友回復：

[code=c]
void CFiberCopyDlg::OnStart()
{
// TODO: Add your control notification handler code here
//
CString prompt;
    LPFIBERDATASTRUCT fs;
    // allocate storage for our fiber data structures
    fs = (LPFIBERDATASTRUCT)HeapAlloc(GetProcessHeap(), 0, sizeof(FIBERDATASTRUCT) * FIBER_COUNT);
    if(fs == NULL)
{
        prompt.Format("HeapAlloc error! (err%=lu)\n", GetLastError());
TRACE0(prompt);
        return ;
    }
    // allocate storage for the read/write buffer
    g_lpBuffer = (LPBYTE)HeapAlloc(GetProcessHeap(), 0, BUFFER_SIZE);
    if(g_lpBuffer == NULL)
{
        prompt.Format("HeapAlloc error! (err%=lu)\n", GetLastError());
TRACE0(prompt);
        return ;
    }
    // open the source file
    fs[READ_FIBER].hFile = CreateFile("..\\REDIST.TXT",GENERIC_READ,FILE_SHARE_READ,
NULL,OPEN_EXISTING,FILE_FLAG_SEQUENTIAL_SCAN,NULL);

    if(fs[READ_FIBER].hFile == INVALID_HANDLE_VALUE)
{
        prompt.Format("HeapAlloc error! (err%=lu)\n", GetLastError());
TRACE0(prompt);
        return ;
    }
    // open the destination file
    fs[WRITE_FIBER].hFile = CreateFile("..\\REDIST_1.TXT",GENERIC_WRITE,0,
NULL, OPEN_ALWAYS , FILE_FLAG_SEQUENTIAL_SCAN, NULL);
    if(fs[WRITE_FIBER].hFile == INVALID_HANDLE_VALUE)
{
prompt.Format("CreateFile error! (err=%lu)\n", GetLastError());
TRACE0(prompt);
return ;
    }
    // convert this thread to a fiber, to allow scheduling of other fibers
    g_lpFiber[PRIMARY_FIBER] = ConvertThreadToFiber(&fs[PRIMARY_FIBER]);
    if(g_lpFiber[PRIMARY_FIBER] == NULL)
{
        prompt.Format("ConvertThreadToFiber failed! err=%lu\n", GetLastError());
TRACE0(prompt);
return ;
    }
    // Just initialize the primary fiber data structure.  We don't use
    // the primary fiber data structure for anything in this sample.
    fs[PRIMARY_FIBER].dwParameter = 0;
    fs[PRIMARY_FIBER].dwFiberResultCode = 0;
    fs[PRIMARY_FIBER].hFile = INVALID_HANDLE_VALUE;
    // create the Read fiber
    g_lpFiber[READ_FIBER] = CreateFiber(0, ReadFiberFunc, &fs[READ_FIBER]);
    if(g_lpFiber[READ_FIBER] == NULL)
{
        prompt.Format("CreateFiber error! (err=%lu)\n", GetLastError());
TRACE0(prompt);
return ;
    }

    fs[READ_FIBER].dwParameter = 0x12345678;
    // create the Write fiber
    g_lpFiber[WRITE_FIBER]=CreateFiber(0, WriteFiberFunc, &fs[WRITE_FIBER]);
    if(g_lpFiber[WRITE_FIBER] == NULL)
{
        prompt.Format("CreateFiber error! (err=%lu)\n", GetLastError());
TRACE0(prompt);
return ;
    }

    fs[WRITE_FIBER].dwParameter = 0x87654321;
    // switch to the read fiber
    SwitchToFiber(g_lpFiber[READ_FIBER]);
    // We have now been scheduled again.  Display results from the read/write
    // fibers
    prompt.Format("ReadFileName:%s.\r\nReadFiber result = %lu.\r\nBytes Processed = %lu\r\n",
"\"..\\REDIST.TXT\"", fs[READ_FIBER].dwFiberResultCode, fs[READ_FIBER].dwBytesProcessed);
m_Edit += prompt;

    prompt.Format("WriteFileName:%s.\r\nWriteFiber result = %lu.\r\nBytes Processed = %lu\r\n",
"\"..\\REDIST_1.TXT\"", fs[WRITE_FIBER].dwFiberResultCode, fs[WRITE_FIBER].dwBytesProcessed);
m_Edit += prompt;
    // Delete the fibers
    DeleteFiber(g_lpFiber[READ_FIBER]);
    DeleteFiber(g_lpFiber[WRITE_FIBER]);
    // close handles
    CloseHandle(fs[READ_FIBER].hFile);
    CloseHandle(fs[WRITE_FIBER].hFile);
    // free allocated memory
    HeapFree(GetProcessHeap(), 0, g_lpBuffer);
    HeapFree(GetProcessHeap(), 0, fs);
//
UpdateData(FALSE);
}

懺程是自調度的 schedule

uj5u.com熱心網友回復：

纖程需要自己去調度，程式員自己的責任；執行緒由內核調度，程式員無須額外的代碼。

uj5u.com熱心網友回復：

參考 3 樓 Eleven的回復:

纖程需要自己去調度，程式員自己的責任；執行緒由內核調度，程式員無須額外的代碼。

我想問的是這樣呼叫纖程和直接呼叫函式有什么區別？

uj5u.com熱心網友回復：

執行緒有同步問題，如果一個執行緒中 while(1){ 判斷讀完沒有；讀函式; 寫函式;) 就沒問題，如果讀函式; 寫函式; 在 2個執行緒就要同步

uj5u.com熱心網友回復：

參考 5 樓 schlafenhamster 的回復:

執行緒有同步問題，如果一個執行緒中 while(1){ 判斷讀完沒有；讀函式; 寫函式;) 就沒問題，如果讀函式; 寫函式; 在 2個執行緒就要同步

是的，我意思就是while(1){ 判斷讀完沒有；讀函式; 寫函式;) 和這個文章例子的纖程有什么區別？！

轉載請註明出處，本文鏈接：https://www.uj5u.com/gongcheng/7390.html

標籤：進程/線程/DLL

上一篇：ActiveX注冊報錯，錯誤代碼0X80040200

下一篇：如何學習Windows編程