pyspark.InheritableThread

pyspark。 InheritableThread ( 目标:可调用的,*arg游戏:任何,* *kwargs:任何 )

线程是推荐用于PySpark代替threading.Thread当固定线程模式启用。使用这个类的完全一样threading.Thread但正确地继承了特定JVM线程如可继承的属性InheritableThreadLocal

同时,注意固定线程模式从Python不关闭连接到JVM线程完成后在Python的一面。这个类,Python执行垃圾收集线程实例并关闭连接正确完成JVM线程。

当固定线程模式,这是threading.Thread

笔记

这个API是实验性的。

方法

getName()

isDaemon()

is_alive()

返回线程是否活着。

加入((超时))

等待该线程终止。

运行()

表示线程的活动方法。

setDaemon(恶魔的)

setName(名字)

开始()

启动线程的活动。

属性

守护进程

一个布尔值,指示是否这个线程是一个守护线程。

鉴别

这个线程的线程标识符或如果它尚未启动。

的名字

一个字符串用于识别目的。

native_id

本机整体这个线程的线程ID,或如果它尚未启动。