data_download.cpp 文件参考

#include <iostream>
#include <queue>
#include <thread>
#include <condition_variable>
#include "NSUKit.h"

浏览源代码.

类
class	ThreadSafeQueue< T >
struct	Deque

类型定义
typedef ThreadSafeQueue< void >	memQueue

函数
void	download_thread (nsukit::BaseKit *_kit, Deque *q, nsuSize_t block, nsuSize_t total, std::mutex *mu)
void	data_generate (nsukit::BaseKit *_kit, Deque *q, nsuSize_t block, std::mutex *mu)
int	main (int argc, char *argv[])

类型定义说明

memQueue

typedef ThreadSafeQueue<void> memQueue

在文件 data_download.cpp 第 69 行定义.

函数说明

data_generate()

void data_generate	(	nsukit::BaseKit *	_kit,
		Deque *	q,
		nsuSize_t	block,
		std::mutex *	mu
	)

参数

_kit
q
block
mu

在文件 data_download.cpp 第 120 行定义.

download_thread()

void download_thread	(	nsukit::BaseKit *	_kit,
		Deque *	q,
		nsuSize_t	block,
		nsuSize_t	total,
		std::mutex *	mu
	)

数据下行线程，从板卡中按粒度捞出数据，将数据推入full队列

参数

_kit	NSUSoc类的实例，与Soc进行数据流交互
q	循环队列
block	数据上行粒度
total	全部数据
mu	互斥锁

在文件 data_download.cpp 第 87 行定义.

main()

int main	(	int	argc,
		char *	argv[]
	)

在文件 data_download.cpp 第 150 行定义.