企业手机网站建设公司,wordpress 标签云制作,idc网站备案,广东响应式网站建设平台并发
什么是并发#xff0c;也就是我们常说的多线程#xff0c;多个程序同时执行。
并发的基础
线程和进程
进程
进程是操作系统中一个重要的概念#xff0c;指的是一个正在运行的程序的实例。它包含程序代码、当前活动的状态、变量、程序计数器和内存等资源。进程是系…并发
什么是并发也就是我们常说的多线程多个程序同时执行。
并发的基础
线程和进程
进程
进程是操作系统中一个重要的概念指的是一个正在运行的程序的实例。它包含程序代码、当前活动的状态、变量、程序计数器和内存等资源。进程是系统进行资源分配和调度的基本单位。
每个进程都有自己的地址空间、数据、堆栈以及其他用于管理其运行的资源。进程之间相互独立通常通过进程间通信IPC来交换数据。
简而言之进程可以被视为一个正在执行的程序管理着程序的执行环境和资源。
线程
线程是进程中的一个执行单位是操作系统中的基本单位应该进程可以有多个线程他们共享一个进程的资源比如内存但是每个线程可以说是相对独立的。
在java和python中有很多方法实现多线程比如java中的Thread类和Runnable接口并且可以通过线程池来管理线程
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;public class Main {public static void main(String[] args) {ExecutorService executor Executors.newFixedThreadPool(2);for (int i 0; i 5; i) {executor.submit(new MyRunnable());}executor.shutdown(); // 关闭线程池}
}
协程(goroutine)
而在go语言中好像并没有线程这一概念只有协程也就是goroutine。相比于线程来说协程更加轻便
在go中启动一个goroutine只需要使用关键词go即可相比于java更加轻便简单
import ( fmt
) func main() { go fmt.Println(goood) fmt.Println(booy)
}可以发现先输出的是booy然后才是goood因为go关键词启动的goroutine不影响main goroutine的执行
管道(chnnel)
在go语言中管道是用于在goroutine之间进行通讯的机制它允许在不同的goroutine之间安全的传递数据
创建管道
它也可以使用make函数创建管道
ch :make(chan int)其中chan关键字就表示channel类型和之前的map和string[]差不多chan也是一个集合类型。
接收和发送数据
chan的操作只有俩种 接收和发送
接收 获取chan中的值-chan 发送 向chan发送值chan-
package mainimport (fmt
)func main() {ch : make(chan int)go func() {ch - 42 // 发送数据到管道}() //执行这个函数的调用value : -ch // 从管道接收数据fmt.Println(value) // 输出: 42
}有缓冲管道与无缓冲管道
在go语言中管道分为有缓冲管道和无缓冲管道他们在数据传输的方式和行为上有一些不同。
无缓冲管道
无缓冲管道就是在定义时不指定容器的管道上面的定义就是无缓冲管道。
特点发送和接收操作是同步的发送方只有到接收方准备好接收数据时才会运行可以确保数据在发送和接收直接有严格同步
上面例子定义的就是无缓冲管道
有缓冲管道
同理有缓冲管道就是在定义时指定了容器的管道
特点发送和接收操作是异步的只要管道没满发送方就不会阻塞只要管道没空接收方也不会阻塞。
ch : make(chan int, 2) // 有缓冲管道容量为 2ch - 1 // 发送数据管道有空间不阻塞
ch - 2 // 发送数据管道仍有空间不阻塞// 此时如果再发送数据发送方会阻塞直到有空间可用
// ch - 3 // 这会导致阻塞fmt.Println(-ch) // 接收数据输出: 1
fmt.Println(-ch) // 接收数据输出: 2
为什么先返回1再返回2接收操作从头部接收而发送操作是从尾部发送所以顺序不变
关闭管道
当不需要使用管道时可以关闭。
close(ch)当管道关闭后无法向里面发送数据但是还是可以向外发送
单向管道
单项管道是指只能用于发送或接收数据的一种管道。可以通过类型声明来创建单向管道从而限制其用法提高代码的安全性和可读性
声明
// 创建一个可以发送的管道
chSend : make(chan- int)// 创建一个可以接收的管道
chReceive : make(-chan int)
如何使用
package mainimport (fmt
)func sendData(ch chan- int) {for i : 0; i 5; i {ch - i // 只能发送数据}close(ch) // 关闭管道
}func receiveData(ch -chan int) {for value : range ch {fmt.Println(value) // 只能接收数据}
}func main() {ch : make(chan int) // 创建一个双向管道go sendData(ch) // 启动发送数据的协程receiveData(ch) // 接收数据
}
可以看到发送的数据被接受并输出并且顺序不变。
